database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

branch-2.1: [Bug](function)window funnel function should support datetimev2 type get scale info #44420 (#44524)

Browse Source 
Cherry-picked from #44420

Co-authored-by: zhangstar333 <zhangsida@selectdb.com>
This commit is contained in:
github-actions[bot]
2024-11-26 12:24:30 +08:00
committed by GitHub
parent 550aa9c3ae
commit e9f4615ddc
3 changed files with 28 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/WindowFunnel.java
View File

@ -45,8 +45,12 @@ public class WindowFunnel extends AggregateFunction
implements ExplicitlyCastableSignature, AlwaysNotNullable {
public static final List<FunctionSignature> SIGNATURES = ImmutableList.of(
FunctionSignature.ret(IntegerType.INSTANCE)
.varArgs(BigIntType.INSTANCE, StringType.INSTANCE, DateTimeV2Type.SYSTEM_DEFAULT,
BooleanType.INSTANCE),
FunctionSignature.ret(IntegerType.INSTANCE)
.varArgs(BigIntType.INSTANCE, StringType.INSTANCE, DateTimeType.INSTANCE, BooleanType.INSTANCE)
);
/**

3
regression-test/data/nereids_p0/aggregate/window_funnel.out
View File

@ -128,3 +128,6 @@
100126 2
100127 2
-- !window_funnel_datetimev2 --
2

21
regression-test/suites/nereids_p0/aggregate/window_funnel.groovy
View File

@ -720,4 +720,25 @@ suite("window_funnel") {
order BY user_id
"""
sql """ DROP TABLE IF EXISTS windowfunnel_test_1 """
sql """
CREATE TABLE windowfunnel_test_1 (
`xwho` varchar(50) NULL COMMENT 'xwho',
`xwhen` datetime(3) COMMENT 'xwhen',
`xwhat` int NULL COMMENT 'xwhat'
) DUPLICATE KEY(xwho)
DISTRIBUTED BY HASH(xwho) BUCKETS 3
PROPERTIES ("replication_num" = "1");
"""
sql """ INSERT INTO windowfunnel_test_1 (xwho, xwhen, xwhat) VALUES
('1', '2022-03-12 10:41:00.111', 1),
('1', '2022-03-12 10:41:00.888', 2),
('1', '2022-03-12 13:28:02.177', 3),
('1', '2022-03-12 16:15:01.444', 4); """
explain {
sql("""select window_funnel(3600 * 3, 'deduplication', t.xwhen, t.xwhat = 1, t.xwhat = 2 ) AS level from windowfunnel_test_1 t;""")
notContains("cast")
}
qt_window_funnel_datetimev2 """select window_funnel(3600 * 3, 'deduplication', t.xwhen, t.xwhat = 1, t.xwhat = 2 ) AS level from windowfunnel_test_1 t; """
}