crp-order-quantity-kpi-service - Details for Query 112

Submitted Time: 2026/04/20 07:08:46
Duration: 3 s
Succeeded Jobs: 231

Plan Visualization

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [id="node0" labelType="html" label="CollectLimit shuffle records written: 37 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 2.2 KiB merged fetch fallback count: 0 local blocks read: 37 remote merged chunks fetched: 0 remote blocks read: 0 local merged bytes read: 0.0 B remote reqs duration: 0 ms local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 7 ms (0 ms, 0 ms, 0 ms (stage 1142.0: task 10746)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 2.2 KiB (62.0 B, 62.0 B, 62.0 B (stage 1142.0: task 10732))" tooltip="CollectLimit 1"]; 1 [id="node1" labelType="html" label="InMemoryTableScan number of output rows: 39,996" tooltip="InMemoryTableScan"]; subgraph cluster2 { isCluster="true"; id="cluster2"; label="WholeStageCodegen (6)\n \nduration: total (min, med, max (stageId: taskId))\n6.2 s (25 ms, 53 ms, 809 ms (stage 1142.0: task 10740))"; tooltip="WholeStageCodegen (6)"; 3 [id="node3" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#28096, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]"]; 4 [id="node4" labelType="html" label="SortMergeJoin number of output rows: 39,996 spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1142.0: task 10732))" tooltip="SortMergeJoin [shardId#445, worklistShardItemId#446L], [shardId#28193, worklistShardItemId#28194L], Inner"]; } subgraph cluster5 { isCluster="true"; id="cluster5"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n3.7 s (14 ms, 68 ms, 406 ms (stage 1142.0: task 10740))"; tooltip="WholeStageCodegen (3)"; 6 [id="node6" labelType="html" label="Sort sort time total (min, med, max (stageId: taskId)) 20 ms (0 ms, 0 ms, 3 ms (stage 1142.0: task 10732)) peak memory total (min, med, max (stageId: taskId)) 76.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1142.0: task 10732)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1142.0: task 10732))" tooltip="Sort [shardId#445 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST], false, 0"]; } 7 [id="node7" labelType="html" label="Exchange shuffle records written: 39,996 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 39,996 local bytes read total (min, med, max (stageId: taskId)) 1190.1 KiB (30.9 KiB, 32.1 KiB, 34.9 KiB (stage 1142.0: task 10749)) merged fetch fallback count: 0 local blocks read: 962 remote merged chunks fetched: 0 remote blocks read: 405 data size total (min, med, max (stageId: taskId)) 24.2 MiB (564.7 KiB, 666.2 KiB, 785.1 KiB (stage 1141.0: task 10676)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 95 ms (1 ms, 1 ms, 17 ms (stage 1141.0: task 10677)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time total (min, med, max (stageId: taskId)) 4 ms (0 ms, 0 ms, 3 ms (stage 1142.0: task 10760)) remote bytes read total (min, med, max (stageId: taskId)) 499.1 KiB (12.7 KiB, 13.4 KiB, 14.7 KiB (stage 1142.0: task 10744)) number of partitions: 37 remote reqs duration total (min, med, max (stageId: taskId)) 1.5 s (3 ms, 7 ms, 440 ms (stage 1142.0: task 10741)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 1689.1 KiB (42.9 KiB, 45.7 KiB, 51.0 KiB (stage 1141.0: task 10599))" tooltip="Exchange hashpartitioning(shardId#445, worklistShardItemId#446L, 37), ENSURE_REQUIREMENTS, [plan_id=118723]"]; 8 [id="node8" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster9 { isCluster="true"; id="cluster9"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n453 ms (0 ms, 5 ms, 28 ms (stage 1141.0: task 10641))"; tooltip="WholeStageCodegen (1)"; 10 [id="node10" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]"]; 11 [id="node11" labelType="html" label="Filter number of output rows: 39,996" tooltip="Filter ((NOT isNewlyCalculated#24690 AND isnotnull(shardId#445)) AND isnotnull(worklistShardItemId#446L))"]; } 12 [id="node12" labelType="html" label="InMemoryTableScan number of output rows: 39,996" tooltip="InMemoryTableScan [demandChannel#24687, demandStream#24688, isNewlyCalculated#24690, kpis#24722, qty#452, shardId#445, worklistShardItemId#446L], [NOT isNewlyCalculated#24690, isnotnull(shardId#445), isnotnull(worklistShardItemId#446L)]"]; 13 [id="node13" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster14 { isCluster="true"; id="cluster14"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 15 [id="node15" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]"]; 16 [id="node16" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti"]; } subgraph cluster17 { isCluster="true"; id="cluster17"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 18 [id="node18" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#445, ) ASC NULLS FIRST, isnull(shardId#445) ASC NULLS FIRST, coalesce(worklistShardItemId#446L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#446L) ASC NULLS FIRST, coalesce(version#447, 0) ASC NULLS FIRST, isnull(version#447) ASC NULLS FIRST, coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))) ASC NULLS FIRST, isnull(qty#452) ASC NULLS FIRST], false, 0"]; } 19 [id="node19" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452), 37), ENSURE_REQUIREMENTS, [plan_id=117747]"]; 20 [id="node20" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]"]; 21 [id="node21" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster22 { isCluster="true"; id="cluster22"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 23 [id="node23" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster24 { isCluster="true"; id="cluster24"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 25 [id="node25" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#24679, ) ASC NULLS FIRST, isnull(shardId#24679) ASC NULLS FIRST, coalesce(worklistShardItemId#24680L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#24680L) ASC NULLS FIRST, coalesce(version#24681, 0) ASC NULLS FIRST, isnull(version#24681) ASC NULLS FIRST, coalesce(product#24682, ) ASC NULLS FIRST, isnull(product#24682) ASC NULLS FIRST, coalesce(plant#24683, ) ASC NULLS FIRST, isnull(plant#24683) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))) ASC NULLS FIRST, isnull(qty#24454) ASC NULLS FIRST], false, 0"]; } 26 [id="node26" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454), 37), ENSURE_REQUIREMENTS, [plan_id=117776]"]; 27 [id="node27" labelType="html" label=" Union " tooltip="Union"]; 28 [id="node28" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]"]; subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 30 [id="node30" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 31 [id="node31" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster32 { isCluster="true"; id="cluster32"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 33 [id="node33" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 34 [id="node34" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 35 [id="node35" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 36 [id="node36" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 37 [id="node37" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster38 { isCluster="true"; id="cluster38"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 39 [id="node39" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 40 [id="node40" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster41 { isCluster="true"; id="cluster41"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 42 [id="node42" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 43 [id="node43" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 44 [id="node44" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster45 { isCluster="true"; id="cluster45"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 46 [id="node46" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster47 { isCluster="true"; id="cluster47"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 48 [id="node48" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 49 [id="node49" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster50 { isCluster="true"; id="cluster50"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 51 [id="node51" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 52 [id="node52" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 53 [id="node53" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster54 { isCluster="true"; id="cluster54"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 55 [id="node55" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 56 [id="node56" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster57 { isCluster="true"; id="cluster57"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 58 [id="node58" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 59 [id="node59" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 60 [id="node60" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } subgraph cluster61 { isCluster="true"; id="cluster61"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 62 [id="node62" labelType="html" label=" Project " tooltip="Project [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]"]; 63 [id="node63" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#24662L, shardId#24661], [cachedWorklistShardItemId#24676L, cachedShardId#24675], Inner"]; } subgraph cluster64 { isCluster="true"; id="cluster64"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 65 [id="node65" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#24662L ASC NULLS FIRST, shardId#24661 ASC NULLS FIRST], false, 0"]; } 66 [id="node66" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#24662L, shardId#24661, 37), ENSURE_REQUIREMENTS, [plan_id=117761]"]; subgraph cluster67 { isCluster="true"; id="cluster67"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 68 [id="node68" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#24668) AND isnotnull(worklistShardItemId#24662L)) AND isnotnull(shardId#24661))"]; } 69 [id="node69" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668], [isnull(qty#24668), isnotnull(worklistShardItemId#24662L), isnotnull(shardId#24661)]"]; 70 [id="node70" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster71 { isCluster="true"; id="cluster71"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 72 [id="node72" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster73 { isCluster="true"; id="cluster73"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 74 [id="node74" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24676L ASC NULLS FIRST, cachedShardId#24675 ASC NULLS FIRST], false, 0"]; } 75 [id="node75" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24676L, cachedShardId#24675, 37), ENSURE_REQUIREMENTS, [plan_id=117767]"]; subgraph cluster76 { isCluster="true"; id="cluster76"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 77 [id="node77" labelType="html" label=" Project " tooltip="Project [shardId#24669 AS cachedShardId#24675, worklistShardItemId#24670L AS cachedWorklistShardItemId#24676L]"]; 78 [id="node78" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24670L) AND isnotnull(shardId#24669))"]; 79 [id="node79" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24669,worklistShardItemId#24670L,qty#24671,demandChannel#24672,demandStream#24673,kpis#24674]"]; } subgraph cluster80 { isCluster="true"; id="cluster80"; label="WholeStageCodegen (9)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (9)"; 81 [id="node81" labelType="html" label=" Project " tooltip="Project [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721, false AS isNewlyCalculated#24691]"]; } 82 [id="node82" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]"]; subgraph cluster83 { isCluster="true"; id="cluster83"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 84 [id="node84" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 85 [id="node85" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster86 { isCluster="true"; id="cluster86"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 87 [id="node87" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 88 [id="node88" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 89 [id="node89" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 90 [id="node90" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 91 [id="node91" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster92 { isCluster="true"; id="cluster92"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 93 [id="node93" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 94 [id="node94" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster95 { isCluster="true"; id="cluster95"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 96 [id="node96" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 97 [id="node97" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 98 [id="node98" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster99 { isCluster="true"; id="cluster99"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 100 [id="node100" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster101 { isCluster="true"; id="cluster101"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 102 [id="node102" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 103 [id="node103" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster104 { isCluster="true"; id="cluster104"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 105 [id="node105" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 106 [id="node106" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 107 [id="node107" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster108 { isCluster="true"; id="cluster108"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 109 [id="node109" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 110 [id="node110" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster111 { isCluster="true"; id="cluster111"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 112 [id="node112" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 113 [id="node113" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 114 [id="node114" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } subgraph cluster115 { isCluster="true"; id="cluster115"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n19 ms (0 ms, 0 ms, 3 ms (stage 1141.0: task 10694))"; tooltip="WholeStageCodegen (2)"; 116 [id="node116" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(shardId#28101) AND isnotnull(worklistShardItemId#28102L))"]; } 117 [id="node117" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#28101, worklistShardItemId#28102L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292], [isnotnull(shardId#28101), isnotnull(worklistShardItemId#28102L)]"]; 118 [id="node118" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[first(kpis#27292, false)])"]; subgraph cluster119 { isCluster="true"; id="cluster119"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 120 [id="node120" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0"]; } 121 [id="node121" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]"]; 122 [id="node122" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[partial_first(kpis#27292, false)])"]; subgraph cluster123 { isCluster="true"; id="cluster123"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 124 [id="node124" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0"]; 125 [id="node125" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]"]; 126 [id="node126" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(product#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257)], [coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449)], Inner, ((qty#27283 <=> qty#452) OR isnull(qty#452))"]; } subgraph cluster127 { isCluster="true"; id="cluster127"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 128 [id="node128" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(product#27256, ) ASC NULLS FIRST, isnull(product#27256) ASC NULLS FIRST, coalesce(plant#27257, ) ASC NULLS FIRST, isnull(plant#27257) ASC NULLS FIRST], false, 0"]; } 129 [id="node129" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(product#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257), 37), ENSURE_REQUIREMENTS, [plan_id=118533]"]; 130 [id="node130" labelType="html" label=" Union " tooltip="Union"]; 131 [id="node131" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27237.productId AS product#27256, prodPlantResults#27237.plantId AS plant#27257, null AS qty#27283, null AS demandChannel#27263, null AS demandStream#27264, transform(prodPlantResults#27237.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27292]"]; 132 [id="node132" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#27237]"]; subgraph cluster133 { isCluster="true"; id="cluster133"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 134 [id="node134" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237]"]; 135 [id="node135" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27230]"]; 136 [id="node136" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))"]; 137 [id="node137" labelType="html" label=" SerializeFromObject " tooltip="SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getNumberOfCalls()), parent, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#27229, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#27230]"]; } 138 [id="node138" labelType="html" label=" Scan " tooltip="Scan[obj#27226]"]; 139 [id="node139" labelType="html" label=" Project " tooltip="Project [_extract_productId#27428 AS product#27243, _extract_plantId#27429 AS plant#27244, quantityKpiResults#27249.quantity AS qty#27250, null AS demandChannel#27252, null AS demandStream#27253, transform(quantityKpiResults#27249.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27426]"]; subgraph cluster140 { isCluster="true"; id="cluster140"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 141 [id="node141" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_quantityKpiResults#27430), [_extract_productId#27428, _extract_plantId#27429], false, [quantityKpiResults#27249]"]; 142 [id="node142" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27282.productId AS _extract_productId#27428, prodPlantResults#27282.plantId AS _extract_plantId#27429, prodPlantResults#27282.quantityKpiResults AS _extract_quantityKpiResults#27430]"]; 143 [id="node143" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#27282.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#27282.quantityKpiResults))"]; } 144 [id="node144" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#27282], [(size(prodPlantResults#27282.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#27282.quantityKpiResults)]"]; subgraph cluster145 { isCluster="true"; id="cluster145"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 146 [id="node146" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237]"]; 147 [id="node147" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27230]"]; 148 [id="node148" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))"]; 149 [id="node149" labelType="html" label=" SerializeFromObject " tooltip="SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getNumberOfCalls()), parent, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#27229, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#27230]"]; } 150 [id="node150" labelType="html" label=" Scan " tooltip="Scan[obj#27226]"]; 151 [id="node151" labelType="html" label=" Project " tooltip="Project [_extract_productId#27431 AS product#27265, _extract_plantId#27432 AS plant#27266, null AS qty#27288, demandChannelStreamKpiResults#27271.demandChannel AS demandChannel#27273, demandChannelStreamKpiResults#27271.demandStream AS demandStream#27275, transform(demandChannelStreamKpiResults#27271.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27427]"]; subgraph cluster152 { isCluster="true"; id="cluster152"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 153 [id="node153" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_demandChannelStreamKpiResults#27433), [_extract_productId#27431, _extract_plantId#27432], false, [demandChannelStreamKpiResults#27271]"]; 154 [id="node154" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27287.productId AS _extract_productId#27431, prodPlantResults#27287.plantId AS _extract_plantId#27432, prodPlantResults#27287.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#27433]"]; 155 [id="node155" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#27287.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#27287.demandChannelStreamKpiResults))"]; } 156 [id="node156" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#27287], [(size(prodPlantResults#27287.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#27287.demandChannelStreamKpiResults)]"]; subgraph cluster157 { isCluster="true"; id="cluster157"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 158 [id="node158" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#27230), false, [prodPlantResults#27237]"]; 159 [id="node159" labelType="html" label=" Project " tooltip="Project [prodPlantResults#27230]"]; 160 [id="node160" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))"]; 161 [id="node161" labelType="html" label=" SerializeFromObject " tooltip="SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getNumberOfCalls()), parent, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#27229, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#27230]"]; } 162 [id="node162" labelType="html" label=" Scan " tooltip="Scan[obj#27226]"]; subgraph cluster163 { isCluster="true"; id="cluster163"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 164 [id="node164" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST], false, 0"]; } 165 [id="node165" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), 37), ENSURE_REQUIREMENTS, [plan_id=118547]"]; subgraph cluster166 { isCluster="true"; id="cluster166"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 167 [id="node167" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448], functions=[])"]; } 168 [id="node168" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448, 37), ENSURE_REQUIREMENTS, [plan_id=118543]"]; subgraph cluster169 { isCluster="true"; id="cluster169"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 170 [id="node170" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#452)) AS qty#452, worklistShardItemId#446L, product#448], functions=[])"]; 171 [id="node171" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]"]; 172 [id="node172" labelType="html" label="Filter number of output rows: 0" tooltip="Filter isNewlyCalculated#24690: boolean"]; } 173 [id="node173" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [isNewlyCalculated#24690, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L], [isNewlyCalculated#24690]"]; 174 [id="node174" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster175 { isCluster="true"; id="cluster175"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 176 [id="node176" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]"]; 177 [id="node177" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti"]; } subgraph cluster178 { isCluster="true"; id="cluster178"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 179 [id="node179" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#445, ) ASC NULLS FIRST, isnull(shardId#445) ASC NULLS FIRST, coalesce(worklistShardItemId#446L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#446L) ASC NULLS FIRST, coalesce(version#447, 0) ASC NULLS FIRST, isnull(version#447) ASC NULLS FIRST, coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))) ASC NULLS FIRST, isnull(qty#452) ASC NULLS FIRST], false, 0"]; } 180 [id="node180" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452), 37), ENSURE_REQUIREMENTS, [plan_id=117747]"]; 181 [id="node181" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]"]; 182 [id="node182" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster183 { isCluster="true"; id="cluster183"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 184 [id="node184" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster185 { isCluster="true"; id="cluster185"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 186 [id="node186" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#24679, ) ASC NULLS FIRST, isnull(shardId#24679) ASC NULLS FIRST, coalesce(worklistShardItemId#24680L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#24680L) ASC NULLS FIRST, coalesce(version#24681, 0) ASC NULLS FIRST, isnull(version#24681) ASC NULLS FIRST, coalesce(product#24682, ) ASC NULLS FIRST, isnull(product#24682) ASC NULLS FIRST, coalesce(plant#24683, ) ASC NULLS FIRST, isnull(plant#24683) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))) ASC NULLS FIRST, isnull(qty#24454) ASC NULLS FIRST], false, 0"]; } 187 [id="node187" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454), 37), ENSURE_REQUIREMENTS, [plan_id=117776]"]; 188 [id="node188" labelType="html" label=" Union " tooltip="Union"]; 189 [id="node189" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]"]; subgraph cluster190 { isCluster="true"; id="cluster190"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 191 [id="node191" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 192 [id="node192" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster193 { isCluster="true"; id="cluster193"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 194 [id="node194" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 195 [id="node195" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 196 [id="node196" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 197 [id="node197" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 198 [id="node198" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster199 { isCluster="true"; id="cluster199"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 200 [id="node200" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 201 [id="node201" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster202 { isCluster="true"; id="cluster202"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 203 [id="node203" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 204 [id="node204" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 205 [id="node205" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster206 { isCluster="true"; id="cluster206"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 207 [id="node207" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster208 { isCluster="true"; id="cluster208"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 209 [id="node209" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 210 [id="node210" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster211 { isCluster="true"; id="cluster211"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 212 [id="node212" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 213 [id="node213" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 214 [id="node214" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster215 { isCluster="true"; id="cluster215"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 216 [id="node216" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 217 [id="node217" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster218 { isCluster="true"; id="cluster218"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 219 [id="node219" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 220 [id="node220" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 221 [id="node221" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } subgraph cluster222 { isCluster="true"; id="cluster222"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 223 [id="node223" labelType="html" label=" Project " tooltip="Project [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]"]; 224 [id="node224" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#24662L, shardId#24661], [cachedWorklistShardItemId#24676L, cachedShardId#24675], Inner"]; } subgraph cluster225 { isCluster="true"; id="cluster225"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 226 [id="node226" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#24662L ASC NULLS FIRST, shardId#24661 ASC NULLS FIRST], false, 0"]; } 227 [id="node227" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#24662L, shardId#24661, 37), ENSURE_REQUIREMENTS, [plan_id=117761]"]; subgraph cluster228 { isCluster="true"; id="cluster228"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 229 [id="node229" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#24668) AND isnotnull(worklistShardItemId#24662L)) AND isnotnull(shardId#24661))"]; } 230 [id="node230" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668], [isnull(qty#24668), isnotnull(worklistShardItemId#24662L), isnotnull(shardId#24661)]"]; 231 [id="node231" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster232 { isCluster="true"; id="cluster232"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 233 [id="node233" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster234 { isCluster="true"; id="cluster234"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 235 [id="node235" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24676L ASC NULLS FIRST, cachedShardId#24675 ASC NULLS FIRST], false, 0"]; } 236 [id="node236" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24676L, cachedShardId#24675, 37), ENSURE_REQUIREMENTS, [plan_id=117767]"]; subgraph cluster237 { isCluster="true"; id="cluster237"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 238 [id="node238" labelType="html" label=" Project " tooltip="Project [shardId#24669 AS cachedShardId#24675, worklistShardItemId#24670L AS cachedWorklistShardItemId#24676L]"]; 239 [id="node239" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24670L) AND isnotnull(shardId#24669))"]; 240 [id="node240" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24669,worklistShardItemId#24670L,qty#24671,demandChannel#24672,demandStream#24673,kpis#24674]"]; } subgraph cluster241 { isCluster="true"; id="cluster241"; label="WholeStageCodegen (9)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (9)"; 242 [id="node242" labelType="html" label=" Project " tooltip="Project [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721, false AS isNewlyCalculated#24691]"]; } 243 [id="node243" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]"]; subgraph cluster244 { isCluster="true"; id="cluster244"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 245 [id="node245" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 246 [id="node246" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster247 { isCluster="true"; id="cluster247"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 248 [id="node248" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 249 [id="node249" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 250 [id="node250" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 251 [id="node251" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 252 [id="node252" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster253 { isCluster="true"; id="cluster253"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 254 [id="node254" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 255 [id="node255" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster256 { isCluster="true"; id="cluster256"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 257 [id="node257" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 258 [id="node258" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 259 [id="node259" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster260 { isCluster="true"; id="cluster260"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 261 [id="node261" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster262 { isCluster="true"; id="cluster262"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 263 [id="node263" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 264 [id="node264" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster265 { isCluster="true"; id="cluster265"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 266 [id="node266" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 267 [id="node267" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 268 [id="node268" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster269 { isCluster="true"; id="cluster269"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 270 [id="node270" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 271 [id="node271" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster272 { isCluster="true"; id="cluster272"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 273 [id="node273" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 274 [id="node274" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 275 [id="node275" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } subgraph cluster276 { isCluster="true"; id="cluster276"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n3.1 s (12 ms, 39 ms, 405 ms (stage 1142.0: task 10740))"; tooltip="WholeStageCodegen (5)"; 277 [id="node277" labelType="html" label="Sort sort time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 1142.0: task 10732)) peak memory total (min, med, max (stageId: taskId)) 76.3 MiB (2.1 MiB, 2.1 MiB, 2.1 MiB (stage 1142.0: task 10732)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1142.0: task 10732))" tooltip="Sort [shardId#28193 ASC NULLS FIRST, worklistShardItemId#28194L ASC NULLS FIRST], false, 0"]; 278 [id="node278" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 225 ms (2 ms, 5 ms, 54 ms (stage 1142.0: task 10746)) peak memory total (min, med, max (stageId: taskId)) 83.3 MiB (2.3 MiB, 2.3 MiB, 2.3 MiB (stage 1142.0: task 10732)) number of output rows: 9,999 number of sort fallback tasks: 0 avg hash probes per key (min, med, max (stageId: taskId)): (1, 1, 1 (stage 1142.0: task 10732))" tooltip="HashAggregate(keys=[shardId#28193, worklistShardItemId#28194L], functions=[max(version#28195)])"]; } 279 [id="node279" labelType="html" label="Exchange shuffle records written: 9,999 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 9,999 local bytes read total (min, med, max (stageId: taskId)) 43.4 KiB (1038.0 B, 1190.0 B, 1407.0 B (stage 1142.0: task 10754)) merged fetch fallback count: 0 local blocks read: 259 remote merged chunks fetched: 0 remote blocks read: 1,108 data size total (min, med, max (stageId: taskId)) 468.7 KiB (10.7 KiB, 12.6 KiB, 14.9 KiB (stage 1140.0: task 10650)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 71 ms (1 ms, 1 ms, 2 ms (stage 1140.0: task 10665)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 1142.0: task 10732)) remote bytes read total (min, med, max (stageId: taskId)) 188.7 KiB (4.8 KiB, 5.1 KiB, 5.3 KiB (stage 1142.0: task 10745)) number of partitions: 37 remote reqs duration total (min, med, max (stageId: taskId)) 1.4 s (3 ms, 7 ms, 439 ms (stage 1142.0: task 10741)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 232.1 KiB (5.8 KiB, 6.3 KiB, 6.8 KiB (stage 1140.0: task 10650))" tooltip="Exchange hashpartitioning(shardId#28193, worklistShardItemId#28194L, 37), ENSURE_REQUIREMENTS, [plan_id=118732]"]; subgraph cluster280 { isCluster="true"; id="cluster280"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n1.3 s (1 ms, 9 ms, 72 ms (stage 1140.0: task 10552))"; tooltip="WholeStageCodegen (4)"; 281 [id="node281" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 116 ms (0 ms, 1 ms, 6 ms (stage 1140.0: task 10547)) peak memory total (min, med, max (stageId: taskId)) 18.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1140.0: task 10558)) number of output rows: 9,999 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#28193, worklistShardItemId#28194L], functions=[partial_max(version#28195)])"]; 282 [id="node282" labelType="html" label="Filter number of output rows: 39,996" tooltip="Filter (isnotnull(shardId#28193) AND isnotnull(worklistShardItemId#28194L))"]; } 283 [id="node283" labelType="html" label="InMemoryTableScan number of output rows: 39,996" tooltip="InMemoryTableScan [shardId#28193, worklistShardItemId#28194L, version#28195], [isnotnull(shardId#28193), isnotnull(worklistShardItemId#28194L)]"]; 284 [id="node284" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster285 { isCluster="true"; id="cluster285"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 286 [id="node286" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]"]; 287 [id="node287" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti"]; } subgraph cluster288 { isCluster="true"; id="cluster288"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 289 [id="node289" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#445, ) ASC NULLS FIRST, isnull(shardId#445) ASC NULLS FIRST, coalesce(worklistShardItemId#446L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#446L) ASC NULLS FIRST, coalesce(version#447, 0) ASC NULLS FIRST, isnull(version#447) ASC NULLS FIRST, coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))) ASC NULLS FIRST, isnull(qty#452) ASC NULLS FIRST], false, 0"]; } 290 [id="node290" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452), 37), ENSURE_REQUIREMENTS, [plan_id=117747]"]; 291 [id="node291" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]"]; 292 [id="node292" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster293 { isCluster="true"; id="cluster293"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 294 [id="node294" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster295 { isCluster="true"; id="cluster295"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 296 [id="node296" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#24679, ) ASC NULLS FIRST, isnull(shardId#24679) ASC NULLS FIRST, coalesce(worklistShardItemId#24680L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#24680L) ASC NULLS FIRST, coalesce(version#24681, 0) ASC NULLS FIRST, isnull(version#24681) ASC NULLS FIRST, coalesce(product#24682, ) ASC NULLS FIRST, isnull(product#24682) ASC NULLS FIRST, coalesce(plant#24683, ) ASC NULLS FIRST, isnull(plant#24683) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))) ASC NULLS FIRST, isnull(qty#24454) ASC NULLS FIRST], false, 0"]; } 297 [id="node297" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454), 37), ENSURE_REQUIREMENTS, [plan_id=117776]"]; 298 [id="node298" labelType="html" label=" Union " tooltip="Union"]; 299 [id="node299" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]"]; subgraph cluster300 { isCluster="true"; id="cluster300"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 301 [id="node301" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 302 [id="node302" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster303 { isCluster="true"; id="cluster303"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 304 [id="node304" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 305 [id="node305" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 306 [id="node306" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 307 [id="node307" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 308 [id="node308" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster309 { isCluster="true"; id="cluster309"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 310 [id="node310" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 311 [id="node311" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster312 { isCluster="true"; id="cluster312"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 313 [id="node313" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 314 [id="node314" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 315 [id="node315" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster316 { isCluster="true"; id="cluster316"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 317 [id="node317" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster318 { isCluster="true"; id="cluster318"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 319 [id="node319" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 320 [id="node320" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster321 { isCluster="true"; id="cluster321"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 322 [id="node322" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 323 [id="node323" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 324 [id="node324" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster325 { isCluster="true"; id="cluster325"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 326 [id="node326" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 327 [id="node327" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster328 { isCluster="true"; id="cluster328"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 329 [id="node329" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 330 [id="node330" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 331 [id="node331" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } subgraph cluster332 { isCluster="true"; id="cluster332"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 333 [id="node333" labelType="html" label=" Project " tooltip="Project [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]"]; 334 [id="node334" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#24662L, shardId#24661], [cachedWorklistShardItemId#24676L, cachedShardId#24675], Inner"]; } subgraph cluster335 { isCluster="true"; id="cluster335"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 336 [id="node336" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#24662L ASC NULLS FIRST, shardId#24661 ASC NULLS FIRST], false, 0"]; } 337 [id="node337" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#24662L, shardId#24661, 37), ENSURE_REQUIREMENTS, [plan_id=117761]"]; subgraph cluster338 { isCluster="true"; id="cluster338"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 339 [id="node339" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#24668) AND isnotnull(worklistShardItemId#24662L)) AND isnotnull(shardId#24661))"]; } 340 [id="node340" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668], [isnull(qty#24668), isnotnull(worklistShardItemId#24662L), isnotnull(shardId#24661)]"]; 341 [id="node341" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster342 { isCluster="true"; id="cluster342"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 343 [id="node343" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster344 { isCluster="true"; id="cluster344"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 345 [id="node345" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24676L ASC NULLS FIRST, cachedShardId#24675 ASC NULLS FIRST], false, 0"]; } 346 [id="node346" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24676L, cachedShardId#24675, 37), ENSURE_REQUIREMENTS, [plan_id=117767]"]; subgraph cluster347 { isCluster="true"; id="cluster347"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 348 [id="node348" labelType="html" label=" Project " tooltip="Project [shardId#24669 AS cachedShardId#24675, worklistShardItemId#24670L AS cachedWorklistShardItemId#24676L]"]; 349 [id="node349" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24670L) AND isnotnull(shardId#24669))"]; 350 [id="node350" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24669,worklistShardItemId#24670L,qty#24671,demandChannel#24672,demandStream#24673,kpis#24674]"]; } subgraph cluster351 { isCluster="true"; id="cluster351"; label="WholeStageCodegen (9)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (9)"; 352 [id="node352" labelType="html" label=" Project " tooltip="Project [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721, false AS isNewlyCalculated#24691]"]; } 353 [id="node353" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]"]; subgraph cluster354 { isCluster="true"; id="cluster354"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (8)"; 355 [id="node355" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]"]; 356 [id="node356" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner"]; } subgraph cluster357 { isCluster="true"; id="cluster357"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 358 [id="node358" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; 359 [id="node359" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 360 [id="node360" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[])"]; 361 [id="node361" labelType="html" label=" Project " tooltip="Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]"]; 362 [id="node362" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24441L, cachedShardId#24440], Inner, ((qty#452 = cachedQty#24442) OR isnull(qty#452))"]; } subgraph cluster363 { isCluster="true"; id="cluster363"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 364 [id="node364" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0"]; } 365 [id="node365" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]"]; subgraph cluster366 { isCluster="true"; id="cluster366"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 367 [id="node367" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))"]; } 368 [id="node368" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]"]; 369 [id="node369" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]"]; subgraph cluster370 { isCluster="true"; id="cluster370"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 371 [id="node371" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#445,worklistShardItemId#446L,version#447,product#448,plant#449,periodStart#450,periodEnd#451,qty#452]"]; } subgraph cluster372 { isCluster="true"; id="cluster372"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 373 [id="node373" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0"]; } 374 [id="node374" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]"]; subgraph cluster375 { isCluster="true"; id="cluster375"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 376 [id="node376" labelType="html" label=" Project " tooltip="Project [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]"]; 377 [id="node377" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))"]; 378 [id="node378" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24434,worklistShardItemId#24435L,qty#24436,demandChannel#24437,demandStream#24438,kpis#24439]"]; } subgraph cluster379 { isCluster="true"; id="cluster379"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 380 [id="node380" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0"]; } 381 [id="node381" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]"]; subgraph cluster382 { isCluster="true"; id="cluster382"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 383 [id="node383" labelType="html" label=" Project " tooltip="Project [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]"]; 384 [id="node384" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))"]; 385 [id="node385" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#24444,worklistShardItemId#24445L,qty#24446,demandChannel#24447,demandStream#24448,kpis#24449]"]; } 1->0; 3->1; 4->3; 6->4; 7->6; 8->7; 10->8; 11->10; 12->11; 13->12; 15->13; 16->15; 18->16; 19->18; 20->19; 21->20; 23->21; 25->16; 26->25; 27->26; 28->27; 30->28; 31->30; 33->31; 34->33; 35->34; 36->35; 37->36; 39->37; 40->39; 42->40; 43->42; 44->43; 46->44; 48->37; 49->48; 51->49; 52->51; 53->52; 55->31; 56->55; 58->56; 59->58; 60->59; 62->27; 63->62; 65->63; 66->65; 68->66; 69->68; 70->69; 72->70; 74->63; 75->74; 77->75; 78->77; 79->78; 81->13; 82->81; 84->82; 85->84; 87->85; 88->87; 89->88; 90->89; 91->90; 93->91; 94->93; 96->94; 97->96; 98->97; 100->98; 102->91; 103->102; 105->103; 106->105; 107->106; 109->85; 110->109; 112->110; 113->112; 114->113; 116->8; 117->116; 118->117; 120->118; 121->120; 122->121; 124->122; 125->124; 126->125; 128->126; 129->128; 130->129; 131->130; 132->131; 134->132; 135->134; 136->135; 137->136; 138->137; 139->130; 141->139; 142->141; 143->142; 144->143; 146->144; 147->146; 148->147; 149->148; 150->149; 151->130; 153->151; 154->153; 155->154; 156->155; 158->156; 159->158; 160->159; 161->160; 162->161; 164->126; 165->164; 167->165; 168->167; 170->168; 171->170; 172->171; 173->172; 174->173; 176->174; 177->176; 179->177; 180->179; 181->180; 182->181; 184->182; 186->177; 187->186; 188->187; 189->188; 191->189; 192->191; 194->192; 195->194; 196->195; 197->196; 198->197; 200->198; 201->200; 203->201; 204->203; 205->204; 207->205; 209->198; 210->209; 212->210; 213->212; 214->213; 216->192; 217->216; 219->217; 220->219; 221->220; 223->188; 224->223; 226->224; 227->226; 229->227; 230->229; 231->230; 233->231; 235->224; 236->235; 238->236; 239->238; 240->239; 242->174; 243->242; 245->243; 246->245; 248->246; 249->248; 250->249; 251->250; 252->251; 254->252; 255->254; 257->255; 258->257; 259->258; 261->259; 263->252; 264->263; 266->264; 267->266; 268->267; 270->246; 271->270; 273->271; 274->273; 275->274; 277->4; 278->277; 279->278; 281->279; 282->281; 283->282; 284->283; 286->284; 287->286; 289->287; 290->289; 291->290; 292->291; 294->292; 296->287; 297->296; 298->297; 299->298; 301->299; 302->301; 304->302; 305->304; 306->305; 307->306; 308->307; 310->308; 311->310; 313->311; 314->313; 315->314; 317->315; 319->308; 320->319; 322->320; 323->322; 324->323; 326->302; 327->326; 329->327; 330->329; 331->330; 333->298; 334->333; 336->334; 337->336; 339->337; 340->339; 341->340; 343->341; 345->334; 346->345; 348->346; 349->348; 350->349; 352->284; 353->352; 355->353; 356->355; 358->356; 359->358; 360->359; 361->360; 362->361; 364->362; 365->364; 367->365; 368->367; 369->368; 371->369; 373->362; 374->373; 376->374; 377->376; 378->377; 380->356; 381->380; 383->381; 384->383; 385->384; }

Details

== Physical Plan ==
CollectLimit (112)
+- InMemoryTableScan (1)
      +- InMemoryRelation (2)
            +- * Project (111)
               +- * SortMergeJoin Inner (110)
                  :- * Sort (102)
                  :  +- Exchange (101)
                  :     +- Union (100)
                  :        :- * Project (57)
                  :        :  +- * Filter (56)
                  :        :     +- InMemoryTableScan (3)
                  :        :           +- InMemoryRelation (4)
                  :        :                 +- Union (55)
                  :        :                    :- * Project (51)
                  :        :                    :  +- * SortMergeJoin LeftAnti (50)
                  :        :                    :     :- * Sort (10)
                  :        :                    :     :  +- Exchange (9)
                  :        :                    :     :     +- InMemoryTableScan (5)
                  :        :                    :     :           +- InMemoryRelation (6)
                  :        :                    :     :                 +- Exchange (8)
                  :        :                    :     :                    +- * Scan ExistingRDD (7)
                  :        :                    :     +- * Sort (49)
                  :        :                    :        +- Exchange (48)
                  :        :                    :           +- Union (47)
                  :        :                    :              :- InMemoryTableScan (11)
                  :        :                    :              :     +- InMemoryRelation (12)
                  :        :                    :              :           +- * Project (34)
                  :        :                    :              :              +- * SortMergeJoin Inner (33)
                  :        :                    :              :                 :- * Sort (27)
                  :        :                    :              :                 :  +- * HashAggregate (26)
                  :        :                    :              :                 :     +- * HashAggregate (25)
                  :        :                    :              :                 :        +- * Project (24)
                  :        :                    :              :                 :           +- * SortMergeJoin Inner (23)
                  :        :                    :              :                 :              :- * Sort (17)
                  :        :                    :              :                 :              :  +- Exchange (16)
                  :        :                    :              :                 :              :     +- * Filter (15)
                  :        :                    :              :                 :              :        +- InMemoryTableScan (13)
                  :        :                    :              :                 :              :              +- InMemoryRelation (14)
                  :        :                    :              :                 :              :                    +- Exchange (8)
                  :        :                    :              :                 :              :                       +- * Scan ExistingRDD (7)
                  :        :                    :              :                 :              +- * Sort (22)
                  :        :                    :              :                 :                 +- Exchange (21)
                  :        :                    :              :                 :                    +- * Project (20)
                  :        :                    :              :                 :                       +- * Filter (19)
                  :        :                    :              :                 :                          +- * Scan ExistingRDD (18)
                  :        :                    :              :                 +- * Sort (32)
                  :        :                    :              :                    +- Exchange (31)
                  :        :                    :              :                       +- * Project (30)
                  :        :                    :              :                          +- * Filter (29)
                  :        :                    :              :                             +- * Scan ExistingRDD (28)
                  :        :                    :              +- * Project (46)
                  :        :                    :                 +- * SortMergeJoin Inner (45)
                  :        :                    :                    :- * Sort (39)
                  :        :                    :                    :  +- Exchange (38)
                  :        :                    :                    :     +- * Filter (37)
                  :        :                    :                    :        +- InMemoryTableScan (35)
                  :        :                    :                    :              +- InMemoryRelation (36)
                  :        :                    :                    :                    +- Exchange (8)
                  :        :                    :                    :                       +- * Scan ExistingRDD (7)
                  :        :                    :                    +- * Sort (44)
                  :        :                    :                       +- Exchange (43)
                  :        :                    :                          +- * Project (42)
                  :        :                    :                             +- * Filter (41)
                  :        :                    :                                +- * Scan ExistingRDD (40)
                  :        :                    +- * Project (54)
                  :        :                       +- InMemoryTableScan (52)
                  :        :                             +- InMemoryRelation (53)
                  :        :                                   +- * Project (34)
                  :        :                                      +- * SortMergeJoin Inner (33)
                  :        :                                         :- * Sort (27)
                  :        :                                         :  +- * HashAggregate (26)
                  :        :                                         :     +- * HashAggregate (25)
                  :        :                                         :        +- * Project (24)
                  :        :                                         :           +- * SortMergeJoin Inner (23)
                  :        :                                         :              :- * Sort (17)
                  :        :                                         :              :  +- Exchange (16)
                  :        :                                         :              :     +- * Filter (15)
                  :        :                                         :              :        +- InMemoryTableScan (13)
                  :        :                                         :              :              +- InMemoryRelation (14)
                  :        :                                         :              :                    +- Exchange (8)
                  :        :                                         :              :                       +- * Scan ExistingRDD (7)
                  :        :                                         :              +- * Sort (22)
                  :        :                                         :                 +- Exchange (21)
                  :        :                                         :                    +- * Project (20)
                  :        :                                         :                       +- * Filter (19)
                  :        :                                         :                          +- * Scan ExistingRDD (18)
                  :        :                                         +- * Sort (32)
                  :        :                                            +- Exchange (31)
                  :        :                                               +- * Project (30)
                  :        :                                                  +- * Filter (29)
                  :        :                                                     +- * Scan ExistingRDD (28)
                  :        +- * Filter (99)
                  :           +- InMemoryTableScan (58)
                  :                 +- InMemoryRelation (59)
                  :                       +- SortAggregate (98)
                  :                          +- * Sort (97)
                  :                             +- Exchange (96)
                  :                                +- SortAggregate (95)
                  :                                   +- * Sort (94)
                  :                                      +- * Project (93)
                  :                                         +- * SortMergeJoin Inner (92)
                  :                                            :- * Sort (82)
                  :                                            :  +- Exchange (81)
                  :                                            :     +- Union (80)
                  :                                            :        :- Project (67)
                  :                                            :        :  +- InMemoryTableScan (60)
                  :                                            :        :        +- InMemoryRelation (61)
                  :                                            :        :              +- * Generate (66)
                  :                                            :        :                 +- * Project (65)
                  :                                            :        :                    +- * Filter (64)
                  :                                            :        :                       +- * SerializeFromObject (63)
                  :                                            :        :                          +- Scan (62)
                  :                                            :        :- Project (73)
                  :                                            :        :  +- * Generate (72)
                  :                                            :        :     +- * Project (71)
                  :                                            :        :        +- * Filter (70)
                  :                                            :        :           +- InMemoryTableScan (68)
                  :                                            :        :                 +- InMemoryRelation (69)
                  :                                            :        :                       +- * Generate (66)
                  :                                            :        :                          +- * Project (65)
                  :                                            :        :                             +- * Filter (64)
                  :                                            :        :                                +- * SerializeFromObject (63)
                  :                                            :        :                                   +- Scan (62)
                  :                                            :        +- Project (79)
                  :                                            :           +- * Generate (78)
                  :                                            :              +- * Project (77)
                  :                                            :                 +- * Filter (76)
                  :                                            :                    +- InMemoryTableScan (74)
                  :                                            :                          +- InMemoryRelation (75)
                  :                                            :                                +- * Generate (66)
                  :                                            :                                   +- * Project (65)
                  :                                            :                                      +- * Filter (64)
                  :                                            :                                         +- * SerializeFromObject (63)
                  :                                            :                                            +- Scan (62)
                  :                                            +- * Sort (91)
                  :                                               +- Exchange (90)
                  :                                                  +- * HashAggregate (89)
                  :                                                     +- Exchange (88)
                  :                                                        +- * HashAggregate (87)
                  :                                                           +- * Project (86)
                  :                                                              +- * Filter (85)
                  :                                                                 +- InMemoryTableScan (83)
                  :                                                                       +- InMemoryRelation (84)
                  :                                                                             +- Union (55)
                  :                                                                                :- * Project (51)
                  :                                                                                :  +- * SortMergeJoin LeftAnti (50)
                  :                                                                                :     :- * Sort (10)
                  :                                                                                :     :  +- Exchange (9)
                  :                                                                                :     :     +- InMemoryTableScan (5)
                  :                                                                                :     :           +- InMemoryRelation (6)
                  :                                                                                :     :                 +- Exchange (8)
                  :                                                                                :     :                    +- * Scan ExistingRDD (7)
                  :                                                                                :     +- * Sort (49)
                  :                                                                                :        +- Exchange (48)
                  :                                                                                :           +- Union (47)
                  :                                                                                :              :- InMemoryTableScan (11)
                  :                                                                                :              :     +- InMemoryRelation (12)
                  :                                                                                :              :           +- * Project (34)
                  :                                                                                :              :              +- * SortMergeJoin Inner (33)
                  :                                                                                :              :                 :- * Sort (27)
                  :                                                                                :              :                 :  +- * HashAggregate (26)
                  :                                                                                :              :                 :     +- * HashAggregate (25)
                  :                                                                                :              :                 :        +- * Project (24)
                  :                                                                                :              :                 :           +- * SortMergeJoin Inner (23)
                  :                                                                                :              :                 :              :- * Sort (17)
                  :                                                                                :              :                 :              :  +- Exchange (16)
                  :                                                                                :              :                 :              :     +- * Filter (15)
                  :                                                                                :              :                 :              :        +- InMemoryTableScan (13)
                  :                                                                                :              :                 :              :              +- InMemoryRelation (14)
                  :                                                                                :              :                 :              :                    +- Exchange (8)
                  :                                                                                :              :                 :              :                       +- * Scan ExistingRDD (7)
                  :                                                                                :              :                 :              +- * Sort (22)
                  :                                                                                :              :                 :                 +- Exchange (21)
                  :                                                                                :              :                 :                    +- * Project (20)
                  :                                                                                :              :                 :                       +- * Filter (19)
                  :                                                                                :              :                 :                          +- * Scan ExistingRDD (18)
                  :                                                                                :              :                 +- * Sort (32)
                  :                                                                                :              :                    +- Exchange (31)
                  :                                                                                :              :                       +- * Project (30)
                  :                                                                                :              :                          +- * Filter (29)
                  :                                                                                :              :                             +- * Scan ExistingRDD (28)
                  :                                                                                :              +- * Project (46)
                  :                                                                                :                 +- * SortMergeJoin Inner (45)
                  :                                                                                :                    :- * Sort (39)
                  :                                                                                :                    :  +- Exchange (38)
                  :                                                                                :                    :     +- * Filter (37)
                  :                                                                                :                    :        +- InMemoryTableScan (35)
                  :                                                                                :                    :              +- InMemoryRelation (36)
                  :                                                                                :                    :                    +- Exchange (8)
                  :                                                                                :                    :                       +- * Scan ExistingRDD (7)
                  :                                                                                :                    +- * Sort (44)
                  :                                                                                :                       +- Exchange (43)
                  :                                                                                :                          +- * Project (42)
                  :                                                                                :                             +- * Filter (41)
                  :                                                                                :                                +- * Scan ExistingRDD (40)
                  :                                                                                +- * Project (54)
                  :                                                                                   +- InMemoryTableScan (52)
                  :                                                                                         +- InMemoryRelation (53)
                  :                                                                                               +- * Project (34)
                  :                                                                                                  +- * SortMergeJoin Inner (33)
                  :                                                                                                     :- * Sort (27)
                  :                                                                                                     :  +- * HashAggregate (26)
                  :                                                                                                     :     +- * HashAggregate (25)
                  :                                                                                                     :        +- * Project (24)
                  :                                                                                                     :           +- * SortMergeJoin Inner (23)
                  :                                                                                                     :              :- * Sort (17)
                  :                                                                                                     :              :  +- Exchange (16)
                  :                                                                                                     :              :     +- * Filter (15)
                  :                                                                                                     :              :        +- InMemoryTableScan (13)
                  :                                                                                                     :              :              +- InMemoryRelation (14)
                  :                                                                                                     :              :                    +- Exchange (8)
                  :                                                                                                     :              :                       +- * Scan ExistingRDD (7)
                  :                                                                                                     :              +- * Sort (22)
                  :                                                                                                     :                 +- Exchange (21)
                  :                                                                                                     :                    +- * Project (20)
                  :                                                                                                     :                       +- * Filter (19)
                  :                                                                                                     :                          +- * Scan ExistingRDD (18)
                  :                                                                                                     +- * Sort (32)
                  :                                                                                                        +- Exchange (31)
                  :                                                                                                           +- * Project (30)
                  :                                                                                                              +- * Filter (29)
                  :                                                                                                                 +- * Scan ExistingRDD (28)
                  +- * Sort (109)
                     +- * HashAggregate (108)
                        +- Exchange (107)
                           +- * HashAggregate (106)
                              +- * Filter (105)
                                 +- InMemoryTableScan (103)
                                       +- InMemoryRelation (104)
                                             +- Union (55)
                                                :- * Project (51)
                                                :  +- * SortMergeJoin LeftAnti (50)
                                                :     :- * Sort (10)
                                                :     :  +- Exchange (9)
                                                :     :     +- InMemoryTableScan (5)
                                                :     :           +- InMemoryRelation (6)
                                                :     :                 +- Exchange (8)
                                                :     :                    +- * Scan ExistingRDD (7)
                                                :     +- * Sort (49)
                                                :        +- Exchange (48)
                                                :           +- Union (47)
                                                :              :- InMemoryTableScan (11)
                                                :              :     +- InMemoryRelation (12)
                                                :              :           +- * Project (34)
                                                :              :              +- * SortMergeJoin Inner (33)
                                                :              :                 :- * Sort (27)
                                                :              :                 :  +- * HashAggregate (26)
                                                :              :                 :     +- * HashAggregate (25)
                                                :              :                 :        +- * Project (24)
                                                :              :                 :           +- * SortMergeJoin Inner (23)
                                                :              :                 :              :- * Sort (17)
                                                :              :                 :              :  +- Exchange (16)
                                                :              :                 :              :     +- * Filter (15)
                                                :              :                 :              :        +- InMemoryTableScan (13)
                                                :              :                 :              :              +- InMemoryRelation (14)
                                                :              :                 :              :                    +- Exchange (8)
                                                :              :                 :              :                       +- * Scan ExistingRDD (7)
                                                :              :                 :              +- * Sort (22)
                                                :              :                 :                 +- Exchange (21)
                                                :              :                 :                    +- * Project (20)
                                                :              :                 :                       +- * Filter (19)
                                                :              :                 :                          +- * Scan ExistingRDD (18)
                                                :              :                 +- * Sort (32)
                                                :              :                    +- Exchange (31)
                                                :              :                       +- * Project (30)
                                                :              :                          +- * Filter (29)
                                                :              :                             +- * Scan ExistingRDD (28)
                                                :              +- * Project (46)
                                                :                 +- * SortMergeJoin Inner (45)
                                                :                    :- * Sort (39)
                                                :                    :  +- Exchange (38)
                                                :                    :     +- * Filter (37)
                                                :                    :        +- InMemoryTableScan (35)
                                                :                    :              +- InMemoryRelation (36)
                                                :                    :                    +- Exchange (8)
                                                :                    :                       +- * Scan ExistingRDD (7)
                                                :                    +- * Sort (44)
                                                :                       +- Exchange (43)
                                                :                          +- * Project (42)
                                                :                             +- * Filter (41)
                                                :                                +- * Scan ExistingRDD (40)
                                                +- * Project (54)
                                                   +- InMemoryTableScan (52)
                                                         +- InMemoryRelation (53)
                                                               +- * Project (34)
                                                                  +- * SortMergeJoin Inner (33)
                                                                     :- * Sort (27)
                                                                     :  +- * HashAggregate (26)
                                                                     :     +- * HashAggregate (25)
                                                                     :        +- * Project (24)
                                                                     :           +- * SortMergeJoin Inner (23)
                                                                     :              :- * Sort (17)
                                                                     :              :  +- Exchange (16)
                                                                     :              :     +- * Filter (15)
                                                                     :              :        +- InMemoryTableScan (13)
                                                                     :              :              +- InMemoryRelation (14)
                                                                     :              :                    +- Exchange (8)
                                                                     :              :                       +- * Scan ExistingRDD (7)
                                                                     :              +- * Sort (22)
                                                                     :                 +- Exchange (21)
                                                                     :                    +- * Project (20)
                                                                     :                       +- * Filter (19)
                                                                     :                          +- * Scan ExistingRDD (18)
                                                                     +- * Sort (32)
                                                                        +- Exchange (31)
                                                                           +- * Project (30)
                                                                              +- * Filter (29)
                                                                                 +- * Scan ExistingRDD (28)


(1) InMemoryTableScan
Output: []

(2) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#28096, qty#452, demandChannel#24687, demandStream#24688, kpis#24722], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [7]: [demandChannel#24687, demandStream#24688, isNewlyCalculated#24690, kpis#24722, qty#452, shardId#445, worklistShardItemId#446L]
Arguments: [demandChannel#24687, demandStream#24688, isNewlyCalculated#24690, kpis#24722, qty#452, shardId#445, worklistShardItemId#446L], [NOT isNewlyCalculated#24690, isnotnull(shardId#445), isnotnull(worklistShardItemId#446L)]

(4) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, demandChannel#24687, demandStream#24688, kpis#24722, isNewlyCalculated#24690], StorageLevel(disk, memory, 2 replicas)

(5) InMemoryTableScan
Output [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]

(6) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452], StorageLevel(disk, memory, 2 replicas)

(7) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452]
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452], SQLExecutionRDD[1452] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(8) Exchange
Input [8]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452]
Arguments: hashpartitioning(product#448, plant#449, 37), REPARTITION_BY_NUM, [plan_id=117521]

(9) Exchange
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: hashpartitioning(coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452), 37), ENSURE_REQUIREMENTS, [plan_id=117747]

(10) Sort [codegen id : 1]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [coalesce(shardId#445, ) ASC NULLS FIRST, isnull(shardId#445) ASC NULLS FIRST, coalesce(worklistShardItemId#446L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#446L) ASC NULLS FIRST, coalesce(version#447, 0) ASC NULLS FIRST, isnull(version#447) ASC NULLS FIRST, coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))) ASC NULLS FIRST, isnull(qty#452) ASC NULLS FIRST], false, 0

(11) InMemoryTableScan
Output [6]: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]
Arguments: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]

(12) InMemoryRelation
Arguments: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454, demandChannel#24447, demandStream#24448, kpis#24455], StorageLevel(disk, memory, 2 replicas)

(13) InMemoryTableScan
Output [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452], [isnotnull(worklistShardItemId#446L), isnotnull(shardId#445)]

(14) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, periodStart#450, periodEnd#451, qty#452], StorageLevel(disk, memory, 2 replicas)

(15) Filter [codegen id : 1]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Condition : (isnotnull(worklistShardItemId#446L) AND isnotnull(shardId#445))

(16) Exchange
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: hashpartitioning(worklistShardItemId#446L, shardId#445, 37), ENSURE_REQUIREMENTS, [plan_id=117630]

(17) Sort [codegen id : 2]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]
Arguments: [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0

(18) Scan ExistingRDD [codegen id : 3]
Output [6]: [shardId#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439]
Arguments: [shardId#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439], MapPartitionsRDD[1474] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(19) Filter [codegen id : 3]
Input [6]: [shardId#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439]
Condition : (isnotnull(worklistShardItemId#24435L) AND isnotnull(shardId#24434))

(20) Project [codegen id : 3]
Output [3]: [shardId#24434 AS cachedShardId#24440, worklistShardItemId#24435L AS cachedWorklistShardItemId#24441L, qty#24436 AS cachedQty#24442]
Input [6]: [shardId#24434, worklistShardItemId#24435L, qty#24436, demandChannel#24437, demandStream#24438, kpis#24439]

(21) Exchange
Input [3]: [cachedShardId#24440, cachedWorklistShardItemId#24441L, cachedQty#24442]
Arguments: hashpartitioning(cachedWorklistShardItemId#24441L, cachedShardId#24440, 37), ENSURE_REQUIREMENTS, [plan_id=117636]

(22) Sort [codegen id : 4]
Input [3]: [cachedShardId#24440, cachedWorklistShardItemId#24441L, cachedQty#24442]
Arguments: [cachedWorklistShardItemId#24441L ASC NULLS FIRST, cachedShardId#24440 ASC NULLS FIRST], false, 0

(23) SortMergeJoin [codegen id : 5]
Left keys [2]: [worklistShardItemId#446L, shardId#445]
Right keys [2]: [cachedWorklistShardItemId#24441L, cachedShardId#24440]
Join type: Inner
Join condition: ((qty#452 = cachedQty#24442) OR isnull(qty#452))

(24) Project [codegen id : 5]
Output [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]
Input [9]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, cachedShardId#24440, cachedWorklistShardItemId#24441L, cachedQty#24442]

(25) HashAggregate [codegen id : 5]
Input [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]
Keys [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]

(26) HashAggregate [codegen id : 5]
Input [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]
Keys [5]: [plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]

(27) Sort [codegen id : 5]
Input [5]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]
Arguments: [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0

(28) Scan ExistingRDD [codegen id : 6]
Output [6]: [shardId#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449]
Arguments: [shardId#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449], MapPartitionsRDD[1474] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(29) Filter [codegen id : 6]
Input [6]: [shardId#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449]
Condition : (isnotnull(worklistShardItemId#24445L) AND isnotnull(shardId#24444))

(30) Project [codegen id : 6]
Output [6]: [shardId#24444 AS cachedShardId#24450, worklistShardItemId#24445L AS cachedWorklistShardItemId#24451L, qty#24446 AS cachedQty#24452, demandChannel#24447, demandStream#24448, kpis#24449 AS cachedKpis#24453]
Input [6]: [shardId#24444, worklistShardItemId#24445L, qty#24446, demandChannel#24447, demandStream#24448, kpis#24449]

(31) Exchange
Input [6]: [cachedShardId#24450, cachedWorklistShardItemId#24451L, cachedQty#24452, demandChannel#24447, demandStream#24448, cachedKpis#24453]
Arguments: hashpartitioning(cachedWorklistShardItemId#24451L, cachedShardId#24450, 37), ENSURE_REQUIREMENTS, [plan_id=117649]

(32) Sort [codegen id : 7]
Input [6]: [cachedShardId#24450, cachedWorklistShardItemId#24451L, cachedQty#24452, demandChannel#24447, demandStream#24448, cachedKpis#24453]
Arguments: [cachedWorklistShardItemId#24451L ASC NULLS FIRST, cachedShardId#24450 ASC NULLS FIRST], false, 0

(33) SortMergeJoin [codegen id : 8]
Left keys [2]: [worklistShardItemId#446L, shardId#445]
Right keys [2]: [cachedWorklistShardItemId#24451L, cachedShardId#24450]
Join type: Inner
Join condition: None

(34) Project [codegen id : 8]
Output [9]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]
Input [11]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedShardId#24450, cachedWorklistShardItemId#24451L, cachedQty#24452, demandChannel#24447, demandStream#24448, cachedKpis#24453]

(35) InMemoryTableScan
Output [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Arguments: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668], [isnull(qty#24668), isnotnull(worklistShardItemId#24662L), isnotnull(shardId#24661)]

(36) InMemoryRelation
Arguments: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, periodStart#24666, periodEnd#24667, qty#24668], StorageLevel(disk, memory, 2 replicas)

(37) Filter [codegen id : 2]
Input [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Condition : ((isnull(qty#24668) AND isnotnull(worklistShardItemId#24662L)) AND isnotnull(shardId#24661))

(38) Exchange
Input [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Arguments: hashpartitioning(worklistShardItemId#24662L, shardId#24661, 37), ENSURE_REQUIREMENTS, [plan_id=117761]

(39) Sort [codegen id : 3]
Input [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Arguments: [worklistShardItemId#24662L ASC NULLS FIRST, shardId#24661 ASC NULLS FIRST], false, 0

(40) Scan ExistingRDD [codegen id : 4]
Output [6]: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674]
Arguments: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674], MapPartitionsRDD[1474] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(41) Filter [codegen id : 4]
Input [6]: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674]
Condition : (isnotnull(worklistShardItemId#24670L) AND isnotnull(shardId#24669))

(42) Project [codegen id : 4]
Output [2]: [shardId#24669 AS cachedShardId#24675, worklistShardItemId#24670L AS cachedWorklistShardItemId#24676L]
Input [6]: [shardId#24669, worklistShardItemId#24670L, qty#24671, demandChannel#24672, demandStream#24673, kpis#24674]

(43) Exchange
Input [2]: [cachedShardId#24675, cachedWorklistShardItemId#24676L]
Arguments: hashpartitioning(cachedWorklistShardItemId#24676L, cachedShardId#24675, 37), ENSURE_REQUIREMENTS, [plan_id=117767]

(44) Sort [codegen id : 5]
Input [2]: [cachedShardId#24675, cachedWorklistShardItemId#24676L]
Arguments: [cachedWorklistShardItemId#24676L ASC NULLS FIRST, cachedShardId#24675 ASC NULLS FIRST], false, 0

(45) SortMergeJoin [codegen id : 6]
Left keys [2]: [worklistShardItemId#24662L, shardId#24661]
Right keys [2]: [cachedWorklistShardItemId#24676L, cachedShardId#24675]
Join type: Inner
Join condition: None

(46) Project [codegen id : 6]
Output [6]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668]
Input [8]: [shardId#24661, worklistShardItemId#24662L, version#24663, product#24664, plant#24665, qty#24668, cachedShardId#24675, cachedWorklistShardItemId#24676L]

(47) Union

(48) Exchange
Input [6]: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]
Arguments: hashpartitioning(coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454), 37), ENSURE_REQUIREMENTS, [plan_id=117776]

(49) Sort [codegen id : 7]
Input [6]: [shardId#24679, worklistShardItemId#24680L, version#24681, product#24682, plant#24683, qty#24454]
Arguments: [coalesce(shardId#24679, ) ASC NULLS FIRST, isnull(shardId#24679) ASC NULLS FIRST, coalesce(worklistShardItemId#24680L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#24680L) ASC NULLS FIRST, coalesce(version#24681, 0) ASC NULLS FIRST, isnull(version#24681) ASC NULLS FIRST, coalesce(product#24682, ) ASC NULLS FIRST, isnull(product#24682) ASC NULLS FIRST, coalesce(plant#24683, ) ASC NULLS FIRST, isnull(plant#24683) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))) ASC NULLS FIRST, isnull(qty#24454) ASC NULLS FIRST], false, 0

(50) SortMergeJoin [codegen id : 8]
Left keys [12]: [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)]
Right keys [12]: [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)]
Join type: LeftAnti
Join condition: None

(51) Project [codegen id : 8]
Output [10]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]
Input [6]: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452]

(52) InMemoryTableScan
Output [9]: [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]
Arguments: [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]

(53) InMemoryRelation
Arguments: [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721], StorageLevel(disk, memory, 2 replicas)

(54) Project [codegen id : 9]
Output [10]: [shardId#24692, worklistShardItemId#24693L, version#24694, product#24695, plant#24696, qty#24720, demandChannel#24713, demandStream#24714, kpis#24721, false AS isNewlyCalculated#24691]
Input [9]: [demandChannel#24713, demandStream#24714, kpis#24721, plant#24696, product#24695, qty#24720, shardId#24692, version#24694, worklistShardItemId#24693L]

(55) Union

(56) Filter [codegen id : 1]
Input [7]: [demandChannel#24687, demandStream#24688, isNewlyCalculated#24690, kpis#24722, qty#452, shardId#445, worklistShardItemId#446L]
Condition : ((NOT isNewlyCalculated#24690 AND isnotnull(shardId#445)) AND isnotnull(worklistShardItemId#446L))

(57) Project [codegen id : 1]
Output [6]: [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]
Input [7]: [demandChannel#24687, demandStream#24688, isNewlyCalculated#24690, kpis#24722, qty#452, shardId#445, worklistShardItemId#446L]

(58) InMemoryTableScan
Output [6]: [shardId#28101, worklistShardItemId#28102L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: [shardId#28101, worklistShardItemId#28102L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292], [isnotnull(shardId#28101), isnotnull(worklistShardItemId#28102L)]

(59) InMemoryRelation
Arguments: [shardId#28101, worklistShardItemId#28102L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292], StorageLevel(disk, memory, 2 replicas)

(60) InMemoryTableScan
Output [1]: [prodPlantResults#27237]
Arguments: [prodPlantResults#27237]

(61) InMemoryRelation
Arguments: [prodPlantResults#27237], StorageLevel(disk, memory, 2 replicas)

(62) Scan
Output [1]: [obj#27226]
Arguments: obj#27226: com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, MapPartitionsRDD[1606] at start at FileStorageAdapterImpl.java:171

(63) SerializeFromObject [codegen id : 1]
Input [1]: [obj#27226]
Arguments: [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getMeasuredUnit()))), numberOfCalls, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getNumberOfCalls()), parent, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getParent()))), runtime, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement))).getRuntime())), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getPerformanceMeasurements()), None) AS performanceMeasurements#27229, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult)))) null else named_struct(demandChannelStreamKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult)))) null else named_struct(demandChannel, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandChannel()))), demandStream, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getDemandStream()))), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -4), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -3), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.DemandChannelStreamKpiResult))).getKpiResults()), None)), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getDemandChannelStreamKpiResults()), None), kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -5), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getKpiResults()), None), plantId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getPlantId()))), productId, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getProductId()))), quantityKpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult)))) null else named_struct(kpiResults, mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult)))) null else named_struct(datetime, static_invoke(DateTimeUtils.fromJavaTimestamp(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getDatetime()))), label, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getLabel()))), value, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -7), StructField(datetime,TimestampType,true), StructField(label,StringType,true), StructField(value,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiResult))).getValue())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getKpiResults()), None), quantity, invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -6), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(quantity,DoubleType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.QuantityKpiResult))).getQuantity())), invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -2), StructField(demandChannelStreamKpiResults,ArrayType(StructType(StructField(demandChannel,StringType,true),StructField(demandStream,StringType,true),StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true)),true),true), StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true), StructField(plantId,StringType,true), StructField(productId,StringType,true), StructField(quantityKpiResults,ArrayType(StructType(StructField(kpiResults,ArrayType(StructType(StructField(datetime,TimestampType,true),StructField(label,StringType,true),StructField(value,DoubleType,false)),true),true),StructField(quantity,DoubleType,false)),true),true), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.ProdPlantKpiCalculationResult))).getQuantityKpiResults()), None)), invoke(knownnotnull(assertnotnull(input[0, com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.KpiCalculationResult, true])).getProdPlantResults()), None) AS prodPlantResults#27230]

(64) Filter [codegen id : 1]
Input [2]: [performanceMeasurements#27229, prodPlantResults#27230]
Condition : ((size(prodPlantResults#27230, true) > 0) AND isnotnull(prodPlantResults#27230))

(65) Project [codegen id : 1]
Output [1]: [prodPlantResults#27230]
Input [2]: [performanceMeasurements#27229, prodPlantResults#27230]

(66) Generate [codegen id : 1]
Input [1]: [prodPlantResults#27230]
Arguments: explode(prodPlantResults#27230), false, [prodPlantResults#27237]

(67) Project
Output [6]: [prodPlantResults#27237.productId AS product#27256, prodPlantResults#27237.plantId AS plant#27257, null AS qty#27283, null AS demandChannel#27263, null AS demandStream#27264, transform(prodPlantResults#27237.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27292]
Input [1]: [prodPlantResults#27237]

(68) InMemoryTableScan
Output [1]: [prodPlantResults#27282]
Arguments: [prodPlantResults#27282], [(size(prodPlantResults#27282.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#27282.quantityKpiResults)]

(69) InMemoryRelation
Arguments: [prodPlantResults#27282], StorageLevel(disk, memory, 2 replicas)

(70) Filter [codegen id : 1]
Input [1]: [prodPlantResults#27282]
Condition : ((size(prodPlantResults#27282.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#27282.quantityKpiResults))

(71) Project [codegen id : 1]
Output [3]: [prodPlantResults#27282.productId AS _extract_productId#27428, prodPlantResults#27282.plantId AS _extract_plantId#27429, prodPlantResults#27282.quantityKpiResults AS _extract_quantityKpiResults#27430]
Input [1]: [prodPlantResults#27282]

(72) Generate [codegen id : 1]
Input [3]: [_extract_productId#27428, _extract_plantId#27429, _extract_quantityKpiResults#27430]
Arguments: explode(_extract_quantityKpiResults#27430), [_extract_productId#27428, _extract_plantId#27429], false, [quantityKpiResults#27249]

(73) Project
Output [6]: [_extract_productId#27428 AS product#27243, _extract_plantId#27429 AS plant#27244, quantityKpiResults#27249.quantity AS qty#27250, null AS demandChannel#27252, null AS demandStream#27253, transform(quantityKpiResults#27249.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27426]
Input [3]: [_extract_productId#27428, _extract_plantId#27429, quantityKpiResults#27249]

(74) InMemoryTableScan
Output [1]: [prodPlantResults#27287]
Arguments: [prodPlantResults#27287], [(size(prodPlantResults#27287.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#27287.demandChannelStreamKpiResults)]

(75) InMemoryRelation
Arguments: [prodPlantResults#27287], StorageLevel(disk, memory, 2 replicas)

(76) Filter [codegen id : 2]
Input [1]: [prodPlantResults#27287]
Condition : ((size(prodPlantResults#27287.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#27287.demandChannelStreamKpiResults))

(77) Project [codegen id : 2]
Output [3]: [prodPlantResults#27287.productId AS _extract_productId#27431, prodPlantResults#27287.plantId AS _extract_plantId#27432, prodPlantResults#27287.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#27433]
Input [1]: [prodPlantResults#27287]

(78) Generate [codegen id : 2]
Input [3]: [_extract_productId#27431, _extract_plantId#27432, _extract_demandChannelStreamKpiResults#27433]
Arguments: explode(_extract_demandChannelStreamKpiResults#27433), [_extract_productId#27431, _extract_plantId#27432], false, [demandChannelStreamKpiResults#27271]

(79) Project
Output [6]: [_extract_productId#27431 AS product#27265, _extract_plantId#27432 AS plant#27266, null AS qty#27288, demandChannelStreamKpiResults#27271.demandChannel AS demandChannel#27273, demandChannelStreamKpiResults#27271.demandStream AS demandStream#27275, transform(demandChannelStreamKpiResults#27271.kpiResults, lambdafunction(struct(label, lambda kpi#27293.label, dateTime, lambda kpi#27293.datetime, value, lambda kpi#27293.value), lambda kpi#27293, false)) AS kpis#27427]
Input [3]: [_extract_productId#27431, _extract_plantId#27432, demandChannelStreamKpiResults#27271]

(80) Union

(81) Exchange
Input [6]: [product#27256, plant#27257, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: hashpartitioning(coalesce(product#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257), 37), ENSURE_REQUIREMENTS, [plan_id=118533]

(82) Sort [codegen id : 3]
Input [6]: [product#27256, plant#27257, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: [coalesce(product#27256, ) ASC NULLS FIRST, isnull(product#27256) ASC NULLS FIRST, coalesce(plant#27257, ) ASC NULLS FIRST, isnull(plant#27257) ASC NULLS FIRST], false, 0

(83) InMemoryTableScan
Output [6]: [isNewlyCalculated#24690, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L]
Arguments: [isNewlyCalculated#24690, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L], [isNewlyCalculated#24690]

(84) InMemoryRelation
Arguments: [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, demandChannel#24687, demandStream#24688, kpis#24722, isNewlyCalculated#24690], StorageLevel(disk, memory, 2 replicas)

(85) Filter [codegen id : 4]
Input [6]: [isNewlyCalculated#24690, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L]
Condition : isNewlyCalculated#24690

(86) Project [codegen id : 4]
Output [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Input [6]: [isNewlyCalculated#24690, plant#449, product#448, qty#452, shardId#445, worklistShardItemId#446L]

(87) HashAggregate [codegen id : 4]
Input [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Keys [5]: [plant#449, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#452)) AS qty#452, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]

(88) Exchange
Input [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]
Arguments: hashpartitioning(plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448, 37), ENSURE_REQUIREMENTS, [plan_id=118543]

(89) HashAggregate [codegen id : 5]
Input [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]
Keys [5]: [plant#449, shardId#445, qty#452, worklistShardItemId#446L, product#448]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]

(90) Exchange
Input [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Arguments: hashpartitioning(coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), 37), ENSURE_REQUIREMENTS, [plan_id=118547]

(91) Sort [codegen id : 6]
Input [5]: [shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]
Arguments: [coalesce(product#448, ) ASC NULLS FIRST, isnull(product#448) ASC NULLS FIRST, coalesce(plant#449, ) ASC NULLS FIRST, isnull(plant#449) ASC NULLS FIRST], false, 0

(92) SortMergeJoin [codegen id : 7]
Left keys [4]: [coalesce(product#27256, ), isnull(product#27256), coalesce(plant#27257, ), isnull(plant#27257)]
Right keys [4]: [coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449)]
Join type: Inner
Join condition: ((qty#27283 <=> qty#452) OR isnull(qty#452))

(93) Project [codegen id : 7]
Output [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Input [11]: [product#27256, plant#27257, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292, shardId#445, worklistShardItemId#446L, product#448, plant#449, qty#452]

(94) Sort [codegen id : 7]
Input [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Arguments: [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0

(95) SortAggregate
Input [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Keys [5]: [demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264]
Functions [1]: [partial_first(kpis#27292, false)]
Aggregate Attributes [2]: [first#27499, valueSet#27500]
Results [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]

(96) Exchange
Input [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]
Arguments: hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]

(97) Sort [codegen id : 8]
Input [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]
Arguments: [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0

(98) SortAggregate
Input [7]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502]
Keys [5]: [demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264]
Functions [1]: [first(kpis#27292, false)]
Aggregate Attributes [1]: [first(kpis#27292)()#27424]
Results [6]: [shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, first(kpis#27292)()#27424 AS kpis#27425]

(99) Filter [codegen id : 2]
Input [6]: [shardId#28101, worklistShardItemId#28102L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27292]
Condition : (isnotnull(shardId#28101) AND isnotnull(worklistShardItemId#28102L))

(100) Union

(101) Exchange
Input [6]: [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]
Arguments: hashpartitioning(shardId#445, worklistShardItemId#446L, 37), ENSURE_REQUIREMENTS, [plan_id=118723]

(102) Sort [codegen id : 3]
Input [6]: [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]
Arguments: [shardId#445 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST], false, 0

(103) InMemoryTableScan
Output [3]: [shardId#28193, worklistShardItemId#28194L, version#28195]
Arguments: [shardId#28193, worklistShardItemId#28194L, version#28195], [isnotnull(shardId#28193), isnotnull(worklistShardItemId#28194L)]

(104) InMemoryRelation
Arguments: [shardId#28193, worklistShardItemId#28194L, version#28195, product#28196, plant#28197, qty#28200, demandChannel#28249, demandStream#28250, kpis#28253, isNewlyCalculated#28252], StorageLevel(disk, memory, 2 replicas)

(105) Filter [codegen id : 4]
Input [3]: [shardId#28193, worklistShardItemId#28194L, version#28195]
Condition : (isnotnull(shardId#28193) AND isnotnull(worklistShardItemId#28194L))

(106) HashAggregate [codegen id : 4]
Input [3]: [shardId#28193, worklistShardItemId#28194L, version#28195]
Keys [2]: [shardId#28193, worklistShardItemId#28194L]
Functions [1]: [partial_max(version#28195)]
Aggregate Attributes [1]: [max#28675]
Results [3]: [shardId#28193, worklistShardItemId#28194L, max#28676]

(107) Exchange
Input [3]: [shardId#28193, worklistShardItemId#28194L, max#28676]
Arguments: hashpartitioning(shardId#28193, worklistShardItemId#28194L, 37), ENSURE_REQUIREMENTS, [plan_id=118732]

(108) HashAggregate [codegen id : 5]
Input [3]: [shardId#28193, worklistShardItemId#28194L, max#28676]
Keys [2]: [shardId#28193, worklistShardItemId#28194L]
Functions [1]: [max(version#28195)]
Aggregate Attributes [1]: [max(version#28195)#28100]
Results [3]: [shardId#28193, worklistShardItemId#28194L, (max(version#28195)#28100 + 1) AS version#28096]

(109) Sort [codegen id : 5]
Input [3]: [shardId#28193, worklistShardItemId#28194L, version#28096]
Arguments: [shardId#28193 ASC NULLS FIRST, worklistShardItemId#28194L ASC NULLS FIRST], false, 0

(110) SortMergeJoin [codegen id : 6]
Left keys [2]: [shardId#445, worklistShardItemId#446L]
Right keys [2]: [shardId#28193, worklistShardItemId#28194L]
Join type: Inner
Join condition: None

(111) Project [codegen id : 6]
Output [7]: [shardId#445, worklistShardItemId#446L, version#28096, qty#452, demandChannel#24687, demandStream#24688, kpis#24722]
Input [9]: [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#24687, demandStream#24688, kpis#24722, shardId#28193, worklistShardItemId#28194L, version#28096]

(112) CollectLimit
Input: []
Arguments: 1

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	2
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
temporal.activity.id	bcc6d1d6-5234-362e-a110-b40301899480
temporal.activity.type	RunStreamWithId