• Submitted Time: 2025/12/06 06:22:00
• Duration: 2 s
• Succeeded Jobs: 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 

== Physical Plan ==
Exchange (16)
+- * Filter (15)
   +- SortAggregate (14)
      +- * Sort (13)
         +- StateStoreSave (12)
            +- SortAggregate (11)
               +- * Sort (10)
                  +- StateStoreRestore (9)
                     +- SortAggregate (8)
                        +- * Sort (7)
                           +- Exchange (6)
                              +- SortAggregate (5)
                                 +- * Sort (4)
                                    +- * Project (3)
                                       +- EventTimeWatermark (2)
                                          +- LocalTableScan (1)


(1) LocalTableScan
Output [6]: [title#28, url#29, uuid#30, inventory_code#32, created_at#33, date#41]
Arguments: <empty>, [title#28, url#29, uuid#30, inventory_code#32, created_at#33, date#41]

(2) EventTimeWatermark
Input [6]: [title#28, url#29, uuid#30, inventory_code#32, created_at#33, date#41]
Arguments: created_at#33: timestamp, 15 minutes

(3) Project [codegen id : 1]
Output [5]: [title#28, url#29, uuid#30, inventory_code#32, date#41]
Input [6]: [title#28, url#29, uuid#30, inventory_code#32, created_at#33-T900000ms, date#41]

(4) Sort [codegen id : 1]
Input [5]: [title#28, url#29, uuid#30, inventory_code#32, date#41]
Arguments: [inventory_code#32 ASC NULLS FIRST, title#28 ASC NULLS FIRST, date#41 ASC NULLS FIRST], false, 0

(5) SortAggregate
Input [5]: [title#28, url#29, uuid#30, inventory_code#32, date#41]
Keys [3]: [inventory_code#32, title#28, date#41]
Functions [3]: [partial_count(1), partial_approx_count_distinct(uuid#30, 0.05, 0, 0), partial_first(url#29, true)]
Aggregate Attributes [3]: [count(1)#847L, approx_count_distinct(uuid#30, 0.05, 0, 0)#953L, first(url#29) ignore nulls#955]
Results [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]

(6) Exchange
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Arguments: hashpartitioning(inventory_code#32, title#28, date#41, 50), ENSURE_REQUIREMENTS, [plan_id=14933]

(7) Sort [codegen id : 2]
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Arguments: [inventory_code#32 ASC NULLS FIRST, title#28 ASC NULLS FIRST, date#41 ASC NULLS FIRST], false, 0

(8) SortAggregate
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Keys [3]: [inventory_code#32, title#28, date#41]
Functions [3]: [merge_count(1), merge_approx_count_distinct(uuid#30, 0.05, 0, 0), merge_first(url#29, true)]
Aggregate Attributes [3]: [count(1)#847L, approx_count_distinct(uuid#30, 0.05, 0, 0)#953L, first(url#29) ignore nulls#955]
Results [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]

(9) StateStoreRestore
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Arguments: [inventory_code#32, title#28, date#41], state info [ checkpoint = <unknown>, runId = a31dc7f8-44a5-4d6c-af75-6fc8af584d26, opId = 0, ver = 0, numPartitions = 50], 2

(10) Sort [codegen id : 3]
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Arguments: [inventory_code#32 ASC NULLS FIRST, title#28 ASC NULLS FIRST, date#41 ASC NULLS FIRST], false, 0

(11) SortAggregate
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Keys [3]: [inventory_code#32, title#28, date#41]
Functions [3]: [merge_count(1), merge_approx_count_distinct(uuid#30, 0.05, 0, 0), merge_first(url#29, true)]
Aggregate Attributes [3]: [count(1)#847L, approx_count_distinct(uuid#30, 0.05, 0, 0)#953L, first(url#29) ignore nulls#955]
Results [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]

(12) StateStoreSave
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Arguments: [inventory_code#32, title#28, date#41], state info [ checkpoint = <unknown>, runId = a31dc7f8-44a5-4d6c-af75-6fc8af584d26, opId = 0, ver = 0, numPartitions = 50], Append, -9223372036854775808, -9223372036854775808, 2

(13) Sort [codegen id : 4]
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Arguments: [inventory_code#32 ASC NULLS FIRST, title#28 ASC NULLS FIRST, date#41 ASC NULLS FIRST], false, 0

(14) SortAggregate
Input [58]: [inventory_code#32, title#28, date#41, count#1195L, MS[0]#1009L, MS[1]#1010L, MS[2]#1011L, MS[3]#1012L, MS[4]#1013L, MS[5]#1014L, MS[6]#1015L, MS[7]#1016L, MS[8]#1017L, MS[9]#1018L, MS[10]#1019L, MS[11]#1020L, MS[12]#1021L, MS[13]#1022L, MS[14]#1023L, MS[15]#1024L, MS[16]#1025L, MS[17]#1026L, MS[18]#1027L, MS[19]#1028L, MS[20]#1029L, MS[21]#1030L, MS[22]#1031L, MS[23]#1032L, MS[24]#1033L, MS[25]#1034L, MS[26]#1035L, MS[27]#1036L, MS[28]#1037L, MS[29]#1038L, MS[30]#1039L, MS[31]#1040L, MS[32]#1041L, MS[33]#1042L, MS[34]#1043L, MS[35]#1044L, MS[36]#1045L, MS[37]#1046L, MS[38]#1047L, MS[39]#1048L, MS[40]#1049L, MS[41]#1050L, MS[42]#1051L, MS[43]#1052L, MS[44]#1053L, MS[45]#1054L, MS[46]#1055L, MS[47]#1056L, MS[48]#1057L, MS[49]#1058L, MS[50]#1059L, MS[51]#1060L, first#1200, valueSet#1201]
Keys [3]: [inventory_code#32, title#28, date#41]
Functions [3]: [count(1), approx_count_distinct(uuid#30, 0.05, 0, 0), first(url#29, true)]
Aggregate Attributes [3]: [count(1)#847L, approx_count_distinct(uuid#30, 0.05, 0, 0)#953L, first(url#29) ignore nulls#955]
Results [6]: [inventory_code#32, title#28, date#41, count(1)#847L AS pv#848L, approx_count_distinct(uuid#30, 0.05, 0, 0)#953L AS uv#954L, first(url#29) ignore nulls#955 AS url#956]

(15) Filter [codegen id : 5]
Input [6]: [inventory_code#32, title#28, date#41, pv#848L, uv#954L, url#956]
Condition : (pv#848L > 10)

(16) Exchange
Input [6]: [inventory_code#32, title#28, date#41, pv#848L, uv#954L, url#956]
Arguments: RoundRobinPartitioning(16), REPARTITION_BY_NUM, [plan_id=14951]