diff --git a/be/src/vec/aggregate_functions/aggregate_function_window.cpp b/be/src/vec/aggregate_functions/aggregate_function_window.cpp index ce82651b3f..4457558818 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_window.cpp +++ b/be/src/vec/aggregate_functions/aggregate_function_window.cpp @@ -106,6 +106,7 @@ void register_aggregate_function_window_rank(AggregateFunctionSimpleFactory& fac creator_without_type::creator); factory.register_function("row_number", creator_without_type::creator); factory.register_function("ntile", creator_without_type::creator); + factory.register_function("cume_dist", creator_without_type::creator); } void register_aggregate_function_window_lead_lag_first_last( diff --git a/be/src/vec/aggregate_functions/aggregate_function_window.h b/be/src/vec/aggregate_functions/aggregate_function_window.h index 7dbe13a840..5ce4649546 100644 --- a/be/src/vec/aggregate_functions/aggregate_function_window.h +++ b/be/src/vec/aggregate_functions/aggregate_function_window.h @@ -231,6 +231,59 @@ public: void deserialize(AggregateDataPtr place, BufferReadable& buf, Arena*) const override {} }; +struct CumeDistData { + int64_t numerator = 0; + int64_t denominator = 0; + int64_t peer_group_start = 0; +}; + +class WindowFunctionCumeDist final + : public IAggregateFunctionDataHelper { +private: + static void check_default(AggregateDataPtr place, int64_t partition_start, + int64_t partition_end) { + if (data(place).denominator == 0) { + data(place).denominator = partition_end - partition_start; + } + } + +public: + WindowFunctionCumeDist(const DataTypes& argument_types_) + : IAggregateFunctionDataHelper(argument_types_) {} + + String get_name() const override { return "cume_dist"; } + + DataTypePtr get_return_type() const override { return std::make_shared(); } + + void add(AggregateDataPtr place, const IColumn**, size_t, Arena*) const override {} + + void add_range_single_place(int64_t partition_start, int64_t partition_end, int64_t frame_start, + int64_t frame_end, AggregateDataPtr place, const IColumn** columns, + Arena* arena) const override { + check_default(place, partition_start, partition_end); + int64_t peer_group_count = frame_end - frame_start; + if (WindowFunctionCumeDist::data(place).peer_group_start != frame_start) { + WindowFunctionCumeDist::data(place).peer_group_start = frame_start; + WindowFunctionCumeDist::data(place).numerator += peer_group_count; + } + } + + void reset(AggregateDataPtr place) const override { + WindowFunctionCumeDist::data(place).numerator = 0; + WindowFunctionCumeDist::data(place).denominator = 0; + WindowFunctionCumeDist::data(place).peer_group_start = -1; + } + + void insert_result_into(ConstAggregateDataPtr place, IColumn& to) const override { + auto cume_dist = data(place).numerator * 1.0 / data(place).denominator; + assert_cast(to).get_data().push_back(cume_dist); + } + + void merge(AggregateDataPtr place, ConstAggregateDataPtr rhs, Arena*) const override {} + void serialize(ConstAggregateDataPtr place, BufferWritable& buf) const override {} + void deserialize(AggregateDataPtr place, BufferReadable& buf, Arena*) const override {} +}; + struct NTileData { int64_t bucket_index = 0; int64_t rows = 0; diff --git a/docs/en/docs/sql-manual/sql-functions/window-functions/window-function-cume-dist.md b/docs/en/docs/sql-manual/sql-functions/window-functions/window-function-cume-dist.md new file mode 100644 index 0000000000..434428875c --- /dev/null +++ b/docs/en/docs/sql-manual/sql-functions/window-functions/window-function-cume-dist.md @@ -0,0 +1,71 @@ +--- +{ + "title": "WINDOW_FUNCTION_CUME_DIST", + "language": "en" +} +--- + + + +## WINDOW FUNCTION CUME_DIST +### description + +CUME_DIST (Cumulative Distribution) is a window function commonly used to calculate the relative ranking of the current row value within a sorted result set. It returns the percentage ranking of the current row value in the result set, i.e., the ratio of the number of rows less than or equal to the current row value to the total number of rows in the result set after sorting. + +```sql +CUME_DIST() OVER(partition_by_clause order_by_clause) +``` + +### example +Suppose there is a table named sales containing sales data, including salesperson name (sales_person), sales amount (sales_amount), and sales date (sales_date). We want to calculate the cumulative percentage of sales amount for each salesperson on each sales date compared to the total sales amount for that day. +```sql +SELECT + sales_person, + sales_date, + sales_amount, + CUME_DIST() OVER (PARTITION BY sales_date ORDER BY sales_amount ASC) AS cumulative_sales_percentage +FROM + sales; +``` + +Suppose the data in the sales table is as follows: + +```sql ++------+--------------+------------+--------------+ +| id | sales_person | sales_date | sales_amount | ++------+--------------+------------+--------------+ +| 1 | Alice | 2024-02-01 | 2000 | +| 2 | Bob | 2024-02-01 | 1500 | +| 3 | Alice | 2024-02-02 | 1800 | +| 4 | Bob | 2024-02-02 | 1200 | +| 5 | Alice | 2024-02-03 | 2200 | +| 6 | Bob | 2024-02-03 | 1900 | +| 7 | Tom | 2024-02-03 | 2000 | +| 8 | Jerry | 2024-02-03 | 2000 | ++------+--------------+------------+--------------+ +``` + +After executing the above SQL query, the result will display the sales amount for each salesperson on each sales date and their cumulative percentage ranking for that sales date. +```sql ++--------------+------------+--------------+-----------------------------+ +| sales_person | sales_date | sales_amount | cumulative_sales_percentage | ++--------------+------------+--------------+-----------------------------+ +| Bob | 2024-02-01 | 1500 | 0.5 | +| Alice | 2024-02-01 | 2000 | 1 | +| Bob | 2024-02-02 | 1200 | 0.5 | +| Alice | 2024-02-02 | 1800 | 1 | +| Bob | 2024-02-03 | 1900 | 0.25 | +| Tom | 2024-02-03 | 2000 | 0.75 | +| Jerry | 2024-02-03 | 2000 | 0.75 | +| Alice | 2024-02-03 | 2200 | 1 | ++--------------+------------+--------------+-----------------------------+ +``` +In this example, the CUME_DIST() function sorts the sales amount for each sales date and then calculates the cumulative percentage of sales amount for each salesperson on that date compared to the total sales amount for that day. Since we use PARTITION BY sales_date, the calculation is done within each sales date, and the sales amount for salespersons on different dates is calculated separately. +### keywords + + WINDOW,FUNCTION,CUME_DIST + diff --git a/docs/sidebars.json b/docs/sidebars.json index 7ee8bb453e..fd429fbfa3 100644 --- a/docs/sidebars.json +++ b/docs/sidebars.json @@ -802,6 +802,7 @@ "sql-manual/sql-functions/window-functions/window-function-rank", "sql-manual/sql-functions/window-functions/window-function-dense-rank", "sql-manual/sql-functions/window-functions/window-function-percent-rank", + "sql-manual/sql-functions/window-functions/window-function-cume-dist", "sql-manual/sql-functions/window-functions/window-function-first-value", "sql-manual/sql-functions/window-functions/window-function-last-value", "sql-manual/sql-functions/window-functions/window-function-lead", diff --git a/docs/zh-CN/docs/sql-manual/sql-functions/window-functions/window-function-cume-dist.md b/docs/zh-CN/docs/sql-manual/sql-functions/window-functions/window-function-cume-dist.md new file mode 100644 index 0000000000..8d1ddea9e8 --- /dev/null +++ b/docs/zh-CN/docs/sql-manual/sql-functions/window-functions/window-function-cume-dist.md @@ -0,0 +1,71 @@ +--- +{ + "title": "WINDOW_FUNCTION_CUME_DIST", + "language": "zh-CN" +} +--- + + + +## WINDOW FUNCTION CUME_DIST +### description + +CUME_DIST (Cumulative Distribution) 是一种窗口函数，它常用于计算当前行值在排序后结果集中的相对排名。它返回的是当前行值在结果集中的百分比排名，即在排序后的结果中小于或等于当前行值的行数与结果集总行数的比例。 + +```sql +CUME_DIST() OVER(partition_by_clause order_by_clause) +``` + +### example +假设有一个表格 sales 包含销售数据，其中包括销售员姓名 (sales_person)、销售额 (sales_amount) 和销售日期 (sales_date)。我们想要计算每个销售员在每个销售日期的销售额占当日总销售额的累积百分比。 + +```sql +SELECT + sales_person, + sales_date, + sales_amount, + CUME_DIST() OVER (PARTITION BY sales_date ORDER BY sales_amount ASC) AS cumulative_sales_percentage +FROM + sales; +``` + +假设表格 sales 中的数据如下： +```sql ++------+--------------+------------+--------------+ +| id | sales_person | sales_date | sales_amount | ++------+--------------+------------+--------------+ +| 1 | Alice | 2024-02-01 | 2000 | +| 2 | Bob | 2024-02-01 | 1500 | +| 3 | Alice | 2024-02-02 | 1800 | +| 4 | Bob | 2024-02-02 | 1200 | +| 5 | Alice | 2024-02-03 | 2200 | +| 6 | Bob | 2024-02-03 | 1900 | +| 7 | Tom | 2024-02-03 | 2000 | +| 8 | Jerry | 2024-02-03 | 2000 | ++------+--------------+------------+--------------+ +``` +执行上述 SQL 查询后，结果将显示每个销售员在每个销售日期的销售额以及其在该销售日期的累积百分比排名。 +```sql ++--------------+------------+--------------+-----------------------------+ +| sales_person | sales_date | sales_amount | cumulative_sales_percentage | ++--------------+------------+--------------+-----------------------------+ +| Bob | 2024-02-01 | 1500 | 0.5 | +| Alice | 2024-02-01 | 2000 | 1 | +| Bob | 2024-02-02 | 1200 | 0.5 | +| Alice | 2024-02-02 | 1800 | 1 | +| Bob | 2024-02-03 | 1900 | 0.25 | +| Tom | 2024-02-03 | 2000 | 0.75 | +| Jerry | 2024-02-03 | 2000 | 0.75 | +| Alice | 2024-02-03 | 2200 | 1 | ++--------------+------------+--------------+-----------------------------+ +``` +在这个例子中，CUME_DIST() 函数根据每个销售日期对销售额进行排序，然后计算每个销售员在该销售日期的销售额占当日总销售额的累积百分比。由于我们使用了 PARTITION BY sales_date，所以计算是在每个销售日期内进行的，销售员在不同日期的销售额被分别计算。 + +### keywords + + WINDOW,FUNCTION,CUME_DIST + diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/BuiltinWindowFunctions.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/BuiltinWindowFunctions.java index a23088d25f..b35903d29f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/BuiltinWindowFunctions.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/BuiltinWindowFunctions.java @@ -17,6 +17,7 @@ package org.apache.doris.catalog; +import org.apache.doris.nereids.trees.expressions.functions.window.CumeDist; import org.apache.doris.nereids.trees.expressions.functions.window.DenseRank; import org.apache.doris.nereids.trees.expressions.functions.window.FirstValue; import org.apache.doris.nereids.trees.expressions.functions.window.Lag; @@ -46,7 +47,8 @@ public class BuiltinWindowFunctions implements FunctionHelper { window(Ntile.class, "ntile"), window(PercentRank.class, "percent_rank"), window(Rank.class, "rank"), - window(RowNumber.class, "row_number") + window(RowNumber.class, "row_number"), + window(CumeDist.class, "cume_dist") ); public static final BuiltinWindowFunctions INSTANCE = new BuiltinWindowFunctions(); diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/FunctionSet.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/FunctionSet.java index 7a16f36546..e2dd59d680 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/FunctionSet.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/FunctionSet.java @@ -1608,6 +1608,14 @@ public class FunctionSet { null, "", "", true)); + // vec cume_dist + addBuiltin(AggregateFunction.createAnalyticBuiltin("cume_dist", + Lists.newArrayList(), Type.DOUBLE, Type.VARCHAR, + "", + "", + null, + "", + "", true)); //vec row_number addBuiltin(AggregateFunction.createAnalyticBuiltin("row_number", new ArrayList(), Type.BIGINT, Type.BIGINT, diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java index 3f805327b2..036b6be8b2 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java @@ -26,6 +26,7 @@ import org.apache.doris.nereids.trees.expressions.WindowFrame; import org.apache.doris.nereids.trees.expressions.WindowFrame.FrameBoundType; import org.apache.doris.nereids.trees.expressions.WindowFrame.FrameBoundary; import org.apache.doris.nereids.trees.expressions.WindowFrame.FrameUnitsType; +import org.apache.doris.nereids.trees.expressions.functions.window.CumeDist; import org.apache.doris.nereids.trees.expressions.functions.window.DenseRank; import org.apache.doris.nereids.trees.expressions.functions.window.FirstOrLastValue; import org.apache.doris.nereids.trees.expressions.functions.window.FirstValue; @@ -387,6 +388,18 @@ public class WindowFunctionChecker extends DefaultExpressionVisitor getSignatures() { + return ImmutableList.of(FunctionSignature.ret(DoubleType.INSTANCE).args()); + } + + @Override + public FunctionSignature searchSignature(List signatures) { + return signatures.get(0); + } + + @Override + public CumeDist withChildren(List children) { + Preconditions.checkArgument(children.size() == 0); + return new CumeDist(); + } + + @Override + public R accept(ExpressionVisitor visitor, C context) { + return visitor.visitCumeDist(this, context); + } +} diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/WindowFunctionVisitor.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/WindowFunctionVisitor.java index 29bbed5322..90782adc8c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/WindowFunctionVisitor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/WindowFunctionVisitor.java @@ -17,6 +17,7 @@ package org.apache.doris.nereids.trees.expressions.visitor; +import org.apache.doris.nereids.trees.expressions.functions.window.CumeDist; import org.apache.doris.nereids.trees.expressions.functions.window.DenseRank; import org.apache.doris.nereids.trees.expressions.functions.window.FirstValue; import org.apache.doris.nereids.trees.expressions.functions.window.Lag; @@ -68,4 +69,8 @@ public interface WindowFunctionVisitor { default R visitRowNumber(RowNumber rowNumber, C context) { return visitWindowFunction(rowNumber, context); } + + default R visitCumeDist(CumeDist cumeDist, C context) { + return visitWindowFunction(cumeDist, context); + } } diff --git a/regression-test/data/nereids_function_p0/window_function/window_fn.out b/regression-test/data/nereids_function_p0/window_function/window_fn.out index 8f51aa3f3c..843598a6c1 100644 --- a/regression-test/data/nereids_function_p0/window_function/window_fn.out +++ b/regression-test/data/nereids_function_p0/window_function/window_fn.out @@ -3538,62 +3538,120 @@ string3 9 3 string3 12 4 -- !sql_percent_rank_pb -- -null 0 -string1 0 -string1 0 -string1 0 -string1 0 -string2 0 -string2 0 -string2 0 -string2 0 -string3 0 -string3 0 -string3 0 -string3 0 +null 0.0 +string1 0.0 +string1 0.0 +string1 0.0 +string1 0.0 +string2 0.0 +string2 0.0 +string2 0.0 +string2 0.0 +string3 0.0 +string3 0.0 +string3 0.0 +string3 0.0 -- !sql_percent_rank_pb_ob -- -null \N 0 -string1 1 0 -string1 4 0.33333333333333331 -string1 7 0.66666666666666663 -string1 10 1 -string2 2 0 -string2 5 0.33333333333333331 -string2 8 0.66666666666666663 -string2 11 1 -string3 3 0 -string3 6 0.33333333333333331 -string3 9 0.66666666666666663 -string3 12 1 +null \N 0.0 +string1 1 0.0 +string1 4 0.3333333333333333 +string1 7 0.6666666666666666 +string1 10 1.0 +string2 2 0.0 +string2 5 0.3333333333333333 +string2 8 0.6666666666666666 +string2 11 1.0 +string3 3 0.0 +string3 6 0.3333333333333333 +string3 9 0.6666666666666666 +string3 12 1.0 -- !sql_percent_rank_pb_notnull -- -string1 0 -string1 0 -string1 0 -string1 0 -string2 0 -string2 0 -string2 0 -string2 0 -string3 0 -string3 0 -string3 0 -string3 0 +string1 0.0 +string1 0.0 +string1 0.0 +string1 0.0 +string2 0.0 +string2 0.0 +string2 0.0 +string2 0.0 +string3 0.0 +string3 0.0 +string3 0.0 +string3 0.0 -- !sql_percent_rank_pb_ob_notnull -- -string1 1 0 -string1 4 0.33333333333333331 -string1 7 0.66666666666666663 -string1 10 1 -string2 2 0 -string2 5 0.33333333333333331 -string2 8 0.66666666666666663 -string2 11 1 -string3 3 0 -string3 6 0.33333333333333331 -string3 9 0.66666666666666663 -string3 12 1 +string1 1 0.0 +string1 4 0.3333333333333333 +string1 7 0.6666666666666666 +string1 10 1.0 +string2 2 0.0 +string2 5 0.3333333333333333 +string2 8 0.6666666666666666 +string2 11 1.0 +string3 3 0.0 +string3 6 0.3333333333333333 +string3 9 0.6666666666666666 +string3 12 1.0 + +-- !sql_cume_dist_pb -- +null 1.0 +string1 1.0 +string1 1.0 +string1 1.0 +string1 1.0 +string2 1.0 +string2 1.0 +string2 1.0 +string2 1.0 +string3 1.0 +string3 1.0 +string3 1.0 +string3 1.0 + +-- !sql_cume_dist_pb_ob -- +null \N 1.0 +string1 1 0.25 +string1 4 0.5 +string1 7 0.75 +string1 10 1.0 +string2 2 0.25 +string2 5 0.5 +string2 8 0.75 +string2 11 1.0 +string3 3 0.25 +string3 6 0.5 +string3 9 0.75 +string3 12 1.0 + +-- !sql_cume_dist_pb_notnull -- +string1 1.0 +string1 1.0 +string1 1.0 +string1 1.0 +string2 1.0 +string2 1.0 +string2 1.0 +string2 1.0 +string3 1.0 +string3 1.0 +string3 1.0 +string3 1.0 + +-- !sql_cume_dist_pb_ob_notnull -- +string1 1 0.25 +string1 4 0.5 +string1 7 0.75 +string1 10 1.0 +string2 2 0.25 +string2 5 0.5 +string2 8 0.75 +string2 11 1.0 +string3 3 0.25 +string3 6 0.5 +string3 9 0.75 +string3 12 1.0 -- !sql_row_number_pb -- null 1 diff --git a/regression-test/data/query_p0/sql_functions/window_functions/test_window_fn.out b/regression-test/data/query_p0/sql_functions/window_functions/test_window_fn.out index f3c5210963..ebb0ebed2f 100644 --- a/regression-test/data/query_p0/sql_functions/window_functions/test_window_fn.out +++ b/regression-test/data/query_p0/sql_functions/window_functions/test_window_fn.out @@ -330,16 +330,28 @@ develop 11 2007-08-15 5200 9 2 3 3 -- !sql -- -0 0 0 -0 0 0 -1 4 0 -0 1 1 -0 1 1 -0.66666666666666663 7 1 -1 9 1 -0 0 2 -0 1 3 -1 3 3 +0.0 0 0 +0.0 0 0 +1.0 4 0 +0.0 1 1 +0.0 1 1 +0.6666666666666666 7 1 +1.0 9 1 +0.0 0 2 +0.0 1 3 +1.0 3 3 + +-- !sql -- +0.6666666666666666 0 0 +0.6666666666666666 0 0 +1.0 4 0 +0.5 1 1 +0.5 1 1 +0.75 7 1 +1.0 9 1 +1.0 0 2 +0.5 1 3 +1.0 3 3 -- !sql -- 0 9976146 4 diff --git a/regression-test/data/query_p0/sql_functions/window_functions/test_window_function.out b/regression-test/data/query_p0/sql_functions/window_functions/test_window_function.out index adcee78250..5cfe5a4280 100644 --- a/regression-test/data/query_p0/sql_functions/window_functions/test_window_function.out +++ b/regression-test/data/query_p0/sql_functions/window_functions/test_window_function.out @@ -206,15 +206,26 @@ JDR 2014-10-08T00:00:00.111111 13.98 14.75 3 2 2 -- !sql -- -1 1 0 +1 1 0.0 1 2 0.5 1 2 0.5 -2 1 0 +2 1 0.0 2 2 0.5 -2 3 1 -3 1 0 -3 1 0 -3 2 1 +2 3 1.0 +3 1 0.0 +3 1 0.0 +3 2 1.0 + +-- !sql -- +1 1 0.3333333333333333 +1 2 1.0 +1 2 1.0 +2 1 0.3333333333333333 +2 2 0.6666666666666666 +2 3 1.0 +3 1 0.6666666666666666 +3 1 0.6666666666666666 +3 2 1.0 -- !sql -- 1 1 1 diff --git a/regression-test/suites/nereids_function_p0/window_function/window_fn.groovy b/regression-test/suites/nereids_function_p0/window_function/window_fn.groovy index 1d66e5ad82..903c59d228 100644 --- a/regression-test/suites/nereids_function_p0/window_function/window_fn.groovy +++ b/regression-test/suites/nereids_function_p0/window_function/window_fn.groovy @@ -650,6 +650,16 @@ suite("nereids_win_fn") { qt_sql_percent_rank_pb_ob_notnull ''' select kstr, kint, percent_rank() over(partition by kstr order by kint) as wf from fn_test_not_nullable order by kstr, kint''' + qt_sql_cume_dist_pb ''' + select kstr, cume_dist() over(partition by kstr) as wf from fn_test order by kstr''' + qt_sql_cume_dist_pb_ob ''' + select kstr, kint, cume_dist() over(partition by kstr order by kint) as wf from fn_test order by kstr, kint''' + + qt_sql_cume_dist_pb_notnull ''' + select kstr, cume_dist() over(partition by kstr) as wf from fn_test_not_nullable order by kstr''' + qt_sql_cume_dist_pb_ob_notnull ''' + select kstr, kint, cume_dist() over(partition by kstr order by kint) as wf from fn_test_not_nullable order by kstr, kint''' + // qt_sql_row_number ''' // select row_number() over() as wf from fn_test''' // qt_sql_row_number_ob ''' @@ -667,4 +677,4 @@ suite("nereids_win_fn") { qt_sql_row_number_pb_ob_notnull ''' select kstr, kint, row_number() over(partition by kstr order by kint) as wf from fn_test_not_nullable order by kstr, kint''' -} \ No newline at end of file +} diff --git a/regression-test/suites/query_p0/sql_functions/window_functions/test_window_fn.groovy b/regression-test/suites/query_p0/sql_functions/window_functions/test_window_fn.groovy index ab35e974b1..165d5cf1d4 100644 --- a/regression-test/suites/query_p0/sql_functions/window_functions/test_window_fn.groovy +++ b/regression-test/suites/query_p0/sql_functions/window_functions/test_window_fn.groovy @@ -220,6 +220,9 @@ suite("test_window_fn", "arrow_flight_sql") { qt_sql """ SELECT percent_rank() OVER (PARTITION BY four ORDER BY ten), ten, four FROM ${tbName2} WHERE unique2 < 10 order by four, ten; """ + qt_sql """ + SELECT cume_dist() OVER (PARTITION BY four ORDER BY ten), ten, four FROM ${tbName2} WHERE unique2 < 10 order by four, ten; + """ qt_sql """ select ten, sum(unique1) + sum(unique2) as res, rank() over (order by sum(unique1) + sum(unique2)) as rank from ${tbName2} group by ten order by ten; """ diff --git a/regression-test/suites/query_p0/sql_functions/window_functions/test_window_function.groovy b/regression-test/suites/query_p0/sql_functions/window_functions/test_window_function.groovy index 1575358b7b..17a21e9350 100644 --- a/regression-test/suites/query_p0/sql_functions/window_functions/test_window_function.groovy +++ b/regression-test/suites/query_p0/sql_functions/window_functions/test_window_function.groovy @@ -291,6 +291,8 @@ suite("test_window_function") { qt_sql """ select /*+SET_VAR(parallel_fragment_exec_instance_num=1) */ x, y, dense_rank() over(partition by x order by y) as rank from ${windowFunctionTable3} order by x, y; """ // PERCENT_RANK qt_sql """ select /*+SET_VAR(parallel_fragment_exec_instance_num=1) */ x, y, percent_rank() over(partition by x order by y) as rank from ${windowFunctionTable3} order by x, y; """ + // CUME_DIST + qt_sql """ select /*+SET_VAR(parallel_fragment_exec_instance_num=1) */ x, y, cume_dist() over(partition by x order by y) as rank from ${windowFunctionTable3} order by x, y; """ // ROW_NUMBER qt_sql """ select /*+SET_VAR(parallel_fragment_exec_instance_num=1) */ x, y, row_number() over(partition by x order by y) as rank from ${windowFunctionTable3} order by x, y; """