@@ -125,7 +125,7 @@ Sink(table=[default_catalog.default_database.sink1], fields=[a, day, EXPR$2, EXP
125
125
+- GroupAggregate(advice=[1], groupBy=[a, day], select=[a, day, SUM_RETRACT(b) AS EXPR$2, COUNT_RETRACT(DISTINCT c) AS EXPR$3])
126
126
+- Exchange(distribution=[hash[a, day]])
127
127
+- Calc(select=[a, day, b0 AS b, c])
128
- +- MultiJoin(joinFilter=[=($0, $4) ], joinTypes=[[ INNER, INNER]], joinConditions=[[ true, =($0, $4)]], joinAttributeMap=[{0=[LeftInputId:-1;LeftFieldIndex:-1;RightInputId:0;RightFieldIndex:0;], 1=[LeftInputId:0;LeftFieldIndex:0;RightInputId:1;RightFieldIndex:2;]}] , select=[a,day,b0,c,d], rowType =[RecordType(INTEGER a, VARCHAR(2147483647) day, BIGINT b0, VARCHAR(2147483647) c, INTEGER d)])
128
+ +- MultiJoin(commonJoinKey=[a ], joinTypes=[INNER, INNER], inputUniqueKeys=[noUniqueKey, noUniqueKey ], joinConditions=[true, =(a, d)], joinFilter=[=(a, d)] , select=[a,day,b0,c,d], outputRowType =[RecordType(INTEGER a, VARCHAR(2147483647) day, BIGINT b0, VARCHAR(2147483647) c, INTEGER d)])
129
129
:- Exchange(distribution=[hash[a]])
130
130
: +- Calc(select=[a, DATE_FORMAT(CURRENT_TIMESTAMP(), 'yyMMdd') AS day])
131
131
: +- TableSourceScan(table=[[default_catalog, default_database, src1, project=[a], metadata=[]]], fields=[a])
@@ -134,7 +134,7 @@ Sink(table=[default_catalog.default_database.sink1], fields=[a, day, EXPR$2, EXP
134
134
135
135
Sink(table=[default_catalog.default_database.sink2], fields=[a, day, b, c])
136
136
+- Calc(select=[a, day, b0 AS b, c])
137
- +- MultiJoin(joinFilter=[=($0, $4) ], joinTypes=[[ INNER, INNER]], joinConditions=[[ true, =($0, $4)]], joinAttributeMap=[{0=[LeftInputId:-1;LeftFieldIndex:-1;RightInputId:0;RightFieldIndex:0;], 1=[LeftInputId:0;LeftFieldIndex:0;RightInputId:1;RightFieldIndex:2;]}] , select=[a,day,b0,c,d], rowType =[RecordType(INTEGER a, VARCHAR(2147483647) day, BIGINT b0, VARCHAR(2147483647) c, INTEGER d)])
137
+ +- MultiJoin(commonJoinKey=[a ], joinTypes=[INNER, INNER], inputUniqueKeys=[noUniqueKey, noUniqueKey ], joinConditions=[true, =(a, d)], joinFilter=[=(a, d)] , select=[a,day,b0,c,d], outputRowType =[RecordType(INTEGER a, VARCHAR(2147483647) day, BIGINT b0, VARCHAR(2147483647) c, INTEGER d)])
138
138
:- Exchange(distribution=[hash[a]])
139
139
: +- Calc(select=[a, DATE_FORMAT(CURRENT_TIMESTAMP(), 'yyMMdd') AS day])
140
140
: +- TableSourceScan(table=[[default_catalog, default_database, src1, project=[a], metadata=[]]], fields=[a])
0 commit comments