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

Submitted Time: 2026/03/20 20:12:20
Duration: 1 s
Succeeded Jobs: 6053 6054

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: 14 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 558.0 B merged fetch fallback count: 0 local blocks read: 9 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)) 2 ms (0 ms, 0 ms, 0 ms (stage 110251.0: task 363991)) 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)) 868.0 B (62.0 B, 62.0 B, 62.0 B (stage 110251.0: task 363976))" tooltip="CollectLimit 1"]; 1 [id="node1" labelType="html" label="InMemoryTableScan number of output rows: 17" tooltip="InMemoryTableScan"]; subgraph cluster2 { isCluster="true"; id="cluster2"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n121 ms (0 ms, 0 ms, 14 ms (stage 110251.0: task 363906))"; tooltip="WholeStageCodegen (5)"; 3 [id="node3" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1059580, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246]"]; 4 [id="node4" labelType="html" label="BroadcastHashJoin number of output rows: 17" tooltip="BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1059677, worklistShardItemId#1059678L], Inner, BuildRight, false"]; } 5 [id="node5" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster6 { isCluster="true"; id="cluster6"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n663 ms (0 ms, 0 ms, 77 ms (stage 110251.0: task 363906))"; tooltip="WholeStageCodegen (1)"; 7 [id="node7" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246]"]; 8 [id="node8" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((NOT isNewlyCalculated#1056214 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))"]; } 9 [id="node9" labelType="html" label="InMemoryTableScan number of output rows: 17" tooltip="InMemoryTableScan [demandChannel#1056211, demandStream#1056212, isNewlyCalculated#1056214, kpis#1056246, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1056214, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]"]; 10 [id="node10" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster11 { isCluster="true"; id="cluster11"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 12 [id="node12" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1056211, null AS demandStream#1056212, [] AS kpis#1056246, true AS isNewlyCalculated#1056214]"]; 13 [id="node13" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978)], LeftAnti"]; } subgraph cluster14 { isCluster="true"; id="cluster14"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 15 [id="node15" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1011815, ) ASC NULLS FIRST, isnull(shardId#1011815) ASC NULLS FIRST, coalesce(worklistShardItemId#1011816L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1011816L) ASC NULLS FIRST, coalesce(version#1011817, 0) ASC NULLS FIRST, isnull(version#1011817) ASC NULLS FIRST, coalesce(product#1011818, ) ASC NULLS FIRST, isnull(product#1011818) ASC NULLS FIRST, coalesce(plant#1011819, ) ASC NULLS FIRST, isnull(plant#1011819) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))) ASC NULLS FIRST, isnull(qty#1011822) ASC NULLS FIRST], false, 0"]; } 16 [id="node16" 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#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822), 37), ENSURE_REQUIREMENTS, [plan_id=1686389]"]; 17 [id="node17" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]"]; 18 [id="node18" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster19 { isCluster="true"; id="cluster19"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 20 [id="node20" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster21 { isCluster="true"; id="cluster21"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 22 [id="node22" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1056203, ) ASC NULLS FIRST, isnull(shardId#1056203) ASC NULLS FIRST, coalesce(worklistShardItemId#1056204L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1056204L) ASC NULLS FIRST, coalesce(version#1056205, 0) ASC NULLS FIRST, isnull(version#1056205) ASC NULLS FIRST, coalesce(product#1056206, ) ASC NULLS FIRST, isnull(product#1056206) ASC NULLS FIRST, coalesce(plant#1056207, ) ASC NULLS FIRST, isnull(plant#1056207) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))) ASC NULLS FIRST, isnull(qty#1055978) ASC NULLS FIRST], false, 0"]; } 23 [id="node23" 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#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978), 37), ENSURE_REQUIREMENTS, [plan_id=1686409]"]; 24 [id="node24" labelType="html" label=" Union " tooltip="Union"]; 25 [id="node25" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978]"]; subgraph cluster26 { isCluster="true"; id="cluster26"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 27 [id="node27" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]"]; 28 [id="node28" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], Inner"]; } subgraph cluster29 { isCluster="true"; id="cluster29"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 30 [id="node30" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0"]; } 31 [id="node31" 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#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]"]; subgraph cluster32 { isCluster="true"; id="cluster32"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 33 [id="node33" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; } 34 [id="node34" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1686273]"]; subgraph cluster35 { isCluster="true"; id="cluster35"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 36 [id="node36" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; 37 [id="node37" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]"]; 38 [id="node38" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055965L, cachedShardId#1055964], Inner, BuildLeft, ((qty#1011822 = cachedQty#1055966) OR isnull(qty#1011822)), false"]; 46 [id="node46" labelType="html" label=" Project " tooltip="Project [shardId#1055958 AS cachedShardId#1055964, worklistShardItemId#1055959L AS cachedWorklistShardItemId#1055965L, qty#1055960 AS cachedQty#1055966]"]; 47 [id="node47" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055959L) AND isnotnull(shardId#1055958))"]; 48 [id="node48" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055958,worklistShardItemId#1055959L,qty#1055960,demandChannel#1055961,demandStream#1055962,kpis#1055963]"]; } 39 [id="node39" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686267]"]; subgraph cluster40 { isCluster="true"; id="cluster40"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 41 [id="node41" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1011816L) AND isnotnull(shardId#1011815))"]; } 42 [id="node42" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822], [isnotnull(worklistShardItemId#1011816L), isnotnull(shardId#1011815)]"]; 43 [id="node43" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster44 { isCluster="true"; id="cluster44"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 45 [id="node45" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster49 { isCluster="true"; id="cluster49"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 50 [id="node50" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1055975L ASC NULLS FIRST, cachedShardId#1055974 ASC NULLS FIRST], false, 0"]; } 51 [id="node51" 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#1055975L, cachedShardId#1055974, 37), ENSURE_REQUIREMENTS, [plan_id=1686283]"]; subgraph cluster52 { isCluster="true"; id="cluster52"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 53 [id="node53" labelType="html" label=" Project " tooltip="Project [shardId#1055968 AS cachedShardId#1055974, worklistShardItemId#1055969L AS cachedWorklistShardItemId#1055975L, qty#1055970 AS cachedQty#1055976, demandChannel#1055971, demandStream#1055972, kpis#1055973 AS cachedKpis#1055977]"]; 54 [id="node54" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055969L) AND isnotnull(shardId#1055968))"]; 55 [id="node55" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055968,worklistShardItemId#1055969L,qty#1055970,demandChannel#1055971,demandStream#1055972,kpis#1055973]"]; } subgraph cluster56 { isCluster="true"; id="cluster56"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 57 [id="node57" labelType="html" label=" Project " tooltip="Project [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192]"]; 58 [id="node58" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1056186L, shardId#1056185], [cachedWorklistShardItemId#1056200L, cachedShardId#1056199], Inner, BuildLeft, false"]; 66 [id="node66" labelType="html" label=" Project " tooltip="Project [shardId#1056193 AS cachedShardId#1056199, worklistShardItemId#1056194L AS cachedWorklistShardItemId#1056200L]"]; 67 [id="node67" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1056194L) AND isnotnull(shardId#1056193))"]; 68 [id="node68" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1056193,worklistShardItemId#1056194L,qty#1056195,demandChannel#1056196,demandStream#1056197,kpis#1056198]"]; } 59 [id="node59" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686403]"]; subgraph cluster60 { isCluster="true"; id="cluster60"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 61 [id="node61" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#1056192) AND isnotnull(worklistShardItemId#1056186L)) AND isnotnull(shardId#1056185))"]; } 62 [id="node62" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192], [isnull(qty#1056192), isnotnull(worklistShardItemId#1056186L), isnotnull(shardId#1056185)]"]; 63 [id="node63" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster64 { isCluster="true"; id="cluster64"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 65 [id="node65" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster69 { isCluster="true"; id="cluster69"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 70 [id="node70" labelType="html" label=" Project " tooltip="Project [shardId#1056216, worklistShardItemId#1056217L, version#1056218, product#1056219, plant#1056220, qty#1056244, demandChannel#1056237, demandStream#1056238, kpis#1056245, false AS isNewlyCalculated#1056215]"]; } 71 [id="node71" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1056237, demandStream#1056238, kpis#1056245, plant#1056220, product#1056219, qty#1056244, shardId#1056216, version#1056218, worklistShardItemId#1056217L]"]; subgraph cluster72 { isCluster="true"; id="cluster72"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 73 [id="node73" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]"]; 74 [id="node74" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], Inner"]; } subgraph cluster75 { isCluster="true"; id="cluster75"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 76 [id="node76" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0"]; } 77 [id="node77" 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#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]"]; subgraph cluster78 { isCluster="true"; id="cluster78"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 79 [id="node79" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; } 80 [id="node80" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1686273]"]; subgraph cluster81 { isCluster="true"; id="cluster81"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 82 [id="node82" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; 83 [id="node83" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]"]; 84 [id="node84" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055965L, cachedShardId#1055964], Inner, BuildLeft, ((qty#1011822 = cachedQty#1055966) OR isnull(qty#1011822)), false"]; 92 [id="node92" labelType="html" label=" Project " tooltip="Project [shardId#1055958 AS cachedShardId#1055964, worklistShardItemId#1055959L AS cachedWorklistShardItemId#1055965L, qty#1055960 AS cachedQty#1055966]"]; 93 [id="node93" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055959L) AND isnotnull(shardId#1055958))"]; 94 [id="node94" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055958,worklistShardItemId#1055959L,qty#1055960,demandChannel#1055961,demandStream#1055962,kpis#1055963]"]; } 85 [id="node85" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686267]"]; subgraph cluster86 { isCluster="true"; id="cluster86"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 87 [id="node87" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1011816L) AND isnotnull(shardId#1011815))"]; } 88 [id="node88" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822], [isnotnull(worklistShardItemId#1011816L), isnotnull(shardId#1011815)]"]; 89 [id="node89" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster90 { isCluster="true"; id="cluster90"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 91 [id="node91" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster95 { isCluster="true"; id="cluster95"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 96 [id="node96" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1055975L ASC NULLS FIRST, cachedShardId#1055974 ASC NULLS FIRST], false, 0"]; } 97 [id="node97" 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#1055975L, cachedShardId#1055974, 37), ENSURE_REQUIREMENTS, [plan_id=1686283]"]; subgraph cluster98 { isCluster="true"; id="cluster98"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 99 [id="node99" labelType="html" label=" Project " tooltip="Project [shardId#1055968 AS cachedShardId#1055974, worklistShardItemId#1055969L AS cachedWorklistShardItemId#1055975L, qty#1055970 AS cachedQty#1055976, demandChannel#1055971, demandStream#1055972, kpis#1055973 AS cachedKpis#1055977]"]; 100 [id="node100" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055969L) AND isnotnull(shardId#1055968))"]; 101 [id="node101" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055968,worklistShardItemId#1055969L,qty#1055970,demandChannel#1055971,demandStream#1055972,kpis#1055973]"]; } subgraph cluster102 { isCluster="true"; id="cluster102"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n8 ms (0 ms, 0 ms, 4 ms (stage 110251.0: task 363976))"; tooltip="WholeStageCodegen (2)"; 103 [id="node103" labelType="html" label="Filter number of output rows: 17" tooltip="Filter (isnotnull(shardId#1059585) AND isnotnull(worklistShardItemId#1059586L))"]; } 104 [id="node104" labelType="html" label="InMemoryTableScan number of output rows: 17" tooltip="InMemoryTableScan [shardId#1059585, worklistShardItemId#1059586L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776], [isnotnull(shardId#1059585), isnotnull(worklistShardItemId#1059586L)]"]; 105 [id="node105" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748], functions=[first(kpis#1058776, false)])"]; subgraph cluster106 { isCluster="true"; id="cluster106"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 107 [id="node107" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#1058747 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1058767 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1058748 ASC NULLS FIRST], false, 0"]; } 108 [id="node108" 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#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748, 37), ENSURE_REQUIREMENTS, [plan_id=1687207]"]; 109 [id="node109" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#1058747, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1058767)) AS qty#1058767, worklistShardItemId#1011816L, demandStream#1058748], functions=[partial_first(kpis#1058776, false)])"]; subgraph cluster110 { isCluster="true"; id="cluster110"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 111 [id="node111" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#1058747 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#1058767)) AS qty#1058767 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1058748 ASC NULLS FIRST], false, 0"]; 112 [id="node112" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776]"]; 113 [id="node113" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [coalesce(product#1058740, ), isnull(product#1058740), coalesce(plant#1058741, ), isnull(plant#1058741)], [coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819)], Inner, BuildRight, ((qty#1058767 <=> qty#1011822) OR isnull(qty#1011822)), false"]; } 114 [id="node114" labelType="html" label=" Union " tooltip="Union"]; 115 [id="node115" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1058721.productId AS product#1058740, prodPlantResults#1058721.plantId AS plant#1058741, null AS qty#1058767, null AS demandChannel#1058747, null AS demandStream#1058748, transform(prodPlantResults#1058721.kpiResults, lambdafunction(struct(label, lambda kpi#1058777.label, dateTime, lambda kpi#1058777.datetime, value, lambda kpi#1058777.value), lambda kpi#1058777, false)) AS kpis#1058776]"]; 116 [id="node116" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1058721]"]; subgraph cluster117 { isCluster="true"; id="cluster117"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 118 [id="node118" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1058714), false, [prodPlantResults#1058721]"]; 119 [id="node119" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1058714]"]; 120 [id="node120" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1058714, true) > 0) AND isnotnull(prodPlantResults#1058714))"]; 121 [id="node121" 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#1058713, 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#1058714]"]; } 122 [id="node122" labelType="html" label=" Scan " tooltip="Scan[obj#1058710]"]; 123 [id="node123" labelType="html" label=" Project " tooltip="Project [_extract_productId#1058912 AS product#1058727, _extract_plantId#1058913 AS plant#1058728, quantityKpiResults#1058733.quantity AS qty#1058734, null AS demandChannel#1058736, null AS demandStream#1058737, transform(quantityKpiResults#1058733.kpiResults, lambdafunction(struct(label, lambda kpi#1058777.label, dateTime, lambda kpi#1058777.datetime, value, lambda kpi#1058777.value), lambda kpi#1058777, false)) AS kpis#1058910]"]; subgraph cluster124 { isCluster="true"; id="cluster124"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 125 [id="node125" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_quantityKpiResults#1058914), [_extract_productId#1058912, _extract_plantId#1058913], false, [quantityKpiResults#1058733]"]; 126 [id="node126" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1058766.productId AS _extract_productId#1058912, prodPlantResults#1058766.plantId AS _extract_plantId#1058913, prodPlantResults#1058766.quantityKpiResults AS _extract_quantityKpiResults#1058914]"]; 127 [id="node127" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#1058766.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#1058766.quantityKpiResults))"]; } 128 [id="node128" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1058766], [(size(prodPlantResults#1058766.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#1058766.quantityKpiResults)]"]; subgraph cluster129 { isCluster="true"; id="cluster129"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 130 [id="node130" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1058714), false, [prodPlantResults#1058721]"]; 131 [id="node131" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1058714]"]; 132 [id="node132" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1058714, true) > 0) AND isnotnull(prodPlantResults#1058714))"]; 133 [id="node133" 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#1058713, 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#1058714]"]; } 134 [id="node134" labelType="html" label=" Scan " tooltip="Scan[obj#1058710]"]; 135 [id="node135" labelType="html" label=" Project " tooltip="Project [_extract_productId#1058915 AS product#1058749, _extract_plantId#1058916 AS plant#1058750, null AS qty#1058772, demandChannelStreamKpiResults#1058755.demandChannel AS demandChannel#1058757, demandChannelStreamKpiResults#1058755.demandStream AS demandStream#1058759, transform(demandChannelStreamKpiResults#1058755.kpiResults, lambdafunction(struct(label, lambda kpi#1058777.label, dateTime, lambda kpi#1058777.datetime, value, lambda kpi#1058777.value), lambda kpi#1058777, false)) AS kpis#1058911]"]; subgraph cluster136 { isCluster="true"; id="cluster136"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 137 [id="node137" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_demandChannelStreamKpiResults#1058917), [_extract_productId#1058915, _extract_plantId#1058916], false, [demandChannelStreamKpiResults#1058755]"]; 138 [id="node138" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1058771.productId AS _extract_productId#1058915, prodPlantResults#1058771.plantId AS _extract_plantId#1058916, prodPlantResults#1058771.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1058917]"]; 139 [id="node139" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#1058771.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#1058771.demandChannelStreamKpiResults))"]; } 140 [id="node140" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1058771], [(size(prodPlantResults#1058771.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#1058771.demandChannelStreamKpiResults)]"]; subgraph cluster141 { isCluster="true"; id="cluster141"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 142 [id="node142" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1058714), false, [prodPlantResults#1058721]"]; 143 [id="node143" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1058714]"]; 144 [id="node144" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1058714, true) > 0) AND isnotnull(prodPlantResults#1058714))"]; 145 [id="node145" 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#1058713, 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#1058714]"]; } 146 [id="node146" labelType="html" label=" Scan " tooltip="Scan[obj#1058710]"]; 147 [id="node147" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, string, true], ), isnull(input[3, string, true])),false), [plan_id=1687200]"]; subgraph cluster148 { isCluster="true"; id="cluster148"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 149 [id="node149" 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#1011819, shardId#1011815, qty#1011822, worklistShardItemId#1011816L, product#1011818], functions=[])"]; } 150 [id="node150" 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#1011819, shardId#1011815, qty#1011822, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1687196]"]; subgraph cluster151 { isCluster="true"; id="cluster151"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 152 [id="node152" 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#1011819, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1011822)) AS qty#1011822, worklistShardItemId#1011816L, product#1011818], functions=[])"]; 153 [id="node153" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, product#1011818, plant#1011819, qty#1011822]"]; 154 [id="node154" labelType="html" label="Filter number of output rows: 0" tooltip="Filter isNewlyCalculated#1056214: boolean"]; } 155 [id="node155" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [isNewlyCalculated#1056214, plant#1011819, product#1011818, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [isNewlyCalculated#1056214]"]; 156 [id="node156" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster157 { isCluster="true"; id="cluster157"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 158 [id="node158" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1056211, null AS demandStream#1056212, [] AS kpis#1056246, true AS isNewlyCalculated#1056214]"]; 159 [id="node159" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978)], LeftAnti"]; } subgraph cluster160 { isCluster="true"; id="cluster160"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 161 [id="node161" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1011815, ) ASC NULLS FIRST, isnull(shardId#1011815) ASC NULLS FIRST, coalesce(worklistShardItemId#1011816L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1011816L) ASC NULLS FIRST, coalesce(version#1011817, 0) ASC NULLS FIRST, isnull(version#1011817) ASC NULLS FIRST, coalesce(product#1011818, ) ASC NULLS FIRST, isnull(product#1011818) ASC NULLS FIRST, coalesce(plant#1011819, ) ASC NULLS FIRST, isnull(plant#1011819) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))) ASC NULLS FIRST, isnull(qty#1011822) ASC NULLS FIRST], false, 0"]; } 162 [id="node162" 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#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822), 37), ENSURE_REQUIREMENTS, [plan_id=1686389]"]; 163 [id="node163" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]"]; 164 [id="node164" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster165 { isCluster="true"; id="cluster165"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 166 [id="node166" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster167 { isCluster="true"; id="cluster167"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 168 [id="node168" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1056203, ) ASC NULLS FIRST, isnull(shardId#1056203) ASC NULLS FIRST, coalesce(worklistShardItemId#1056204L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1056204L) ASC NULLS FIRST, coalesce(version#1056205, 0) ASC NULLS FIRST, isnull(version#1056205) ASC NULLS FIRST, coalesce(product#1056206, ) ASC NULLS FIRST, isnull(product#1056206) ASC NULLS FIRST, coalesce(plant#1056207, ) ASC NULLS FIRST, isnull(plant#1056207) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))) ASC NULLS FIRST, isnull(qty#1055978) ASC NULLS FIRST], false, 0"]; } 169 [id="node169" 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#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978), 37), ENSURE_REQUIREMENTS, [plan_id=1686409]"]; 170 [id="node170" labelType="html" label=" Union " tooltip="Union"]; 171 [id="node171" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978]"]; subgraph cluster172 { isCluster="true"; id="cluster172"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 173 [id="node173" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]"]; 174 [id="node174" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], Inner"]; } subgraph cluster175 { isCluster="true"; id="cluster175"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 176 [id="node176" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0"]; } 177 [id="node177" 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#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]"]; subgraph cluster178 { isCluster="true"; id="cluster178"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 179 [id="node179" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; } 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(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1686273]"]; subgraph cluster181 { isCluster="true"; id="cluster181"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 182 [id="node182" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; 183 [id="node183" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]"]; 184 [id="node184" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055965L, cachedShardId#1055964], Inner, BuildLeft, ((qty#1011822 = cachedQty#1055966) OR isnull(qty#1011822)), false"]; 192 [id="node192" labelType="html" label=" Project " tooltip="Project [shardId#1055958 AS cachedShardId#1055964, worklistShardItemId#1055959L AS cachedWorklistShardItemId#1055965L, qty#1055960 AS cachedQty#1055966]"]; 193 [id="node193" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055959L) AND isnotnull(shardId#1055958))"]; 194 [id="node194" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055958,worklistShardItemId#1055959L,qty#1055960,demandChannel#1055961,demandStream#1055962,kpis#1055963]"]; } 185 [id="node185" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686267]"]; subgraph cluster186 { isCluster="true"; id="cluster186"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 187 [id="node187" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1011816L) AND isnotnull(shardId#1011815))"]; } 188 [id="node188" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822], [isnotnull(worklistShardItemId#1011816L), isnotnull(shardId#1011815)]"]; 189 [id="node189" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster190 { isCluster="true"; id="cluster190"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 191 [id="node191" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster195 { isCluster="true"; id="cluster195"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 196 [id="node196" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1055975L ASC NULLS FIRST, cachedShardId#1055974 ASC NULLS FIRST], false, 0"]; } 197 [id="node197" 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#1055975L, cachedShardId#1055974, 37), ENSURE_REQUIREMENTS, [plan_id=1686283]"]; subgraph cluster198 { isCluster="true"; id="cluster198"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 199 [id="node199" labelType="html" label=" Project " tooltip="Project [shardId#1055968 AS cachedShardId#1055974, worklistShardItemId#1055969L AS cachedWorklistShardItemId#1055975L, qty#1055970 AS cachedQty#1055976, demandChannel#1055971, demandStream#1055972, kpis#1055973 AS cachedKpis#1055977]"]; 200 [id="node200" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055969L) AND isnotnull(shardId#1055968))"]; 201 [id="node201" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055968,worklistShardItemId#1055969L,qty#1055970,demandChannel#1055971,demandStream#1055972,kpis#1055973]"]; } subgraph cluster202 { isCluster="true"; id="cluster202"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 203 [id="node203" labelType="html" label=" Project " tooltip="Project [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192]"]; 204 [id="node204" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1056186L, shardId#1056185], [cachedWorklistShardItemId#1056200L, cachedShardId#1056199], Inner, BuildLeft, false"]; 212 [id="node212" labelType="html" label=" Project " tooltip="Project [shardId#1056193 AS cachedShardId#1056199, worklistShardItemId#1056194L AS cachedWorklistShardItemId#1056200L]"]; 213 [id="node213" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1056194L) AND isnotnull(shardId#1056193))"]; 214 [id="node214" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1056193,worklistShardItemId#1056194L,qty#1056195,demandChannel#1056196,demandStream#1056197,kpis#1056198]"]; } 205 [id="node205" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686403]"]; subgraph cluster206 { isCluster="true"; id="cluster206"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 207 [id="node207" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#1056192) AND isnotnull(worklistShardItemId#1056186L)) AND isnotnull(shardId#1056185))"]; } 208 [id="node208" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192], [isnull(qty#1056192), isnotnull(worklistShardItemId#1056186L), isnotnull(shardId#1056185)]"]; 209 [id="node209" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster210 { isCluster="true"; id="cluster210"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 211 [id="node211" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster215 { isCluster="true"; id="cluster215"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 216 [id="node216" labelType="html" label=" Project " tooltip="Project [shardId#1056216, worklistShardItemId#1056217L, version#1056218, product#1056219, plant#1056220, qty#1056244, demandChannel#1056237, demandStream#1056238, kpis#1056245, false AS isNewlyCalculated#1056215]"]; } 217 [id="node217" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1056237, demandStream#1056238, kpis#1056245, plant#1056220, product#1056219, qty#1056244, shardId#1056216, version#1056218, worklistShardItemId#1056217L]"]; subgraph cluster218 { isCluster="true"; id="cluster218"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 219 [id="node219" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]"]; 220 [id="node220" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], Inner"]; } subgraph cluster221 { isCluster="true"; id="cluster221"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 222 [id="node222" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0"]; } 223 [id="node223" 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#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]"]; subgraph cluster224 { isCluster="true"; id="cluster224"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 225 [id="node225" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; } 226 [id="node226" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1686273]"]; subgraph cluster227 { isCluster="true"; id="cluster227"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 228 [id="node228" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; 229 [id="node229" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]"]; 230 [id="node230" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055965L, cachedShardId#1055964], Inner, BuildLeft, ((qty#1011822 = cachedQty#1055966) OR isnull(qty#1011822)), false"]; 238 [id="node238" labelType="html" label=" Project " tooltip="Project [shardId#1055958 AS cachedShardId#1055964, worklistShardItemId#1055959L AS cachedWorklistShardItemId#1055965L, qty#1055960 AS cachedQty#1055966]"]; 239 [id="node239" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055959L) AND isnotnull(shardId#1055958))"]; 240 [id="node240" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055958,worklistShardItemId#1055959L,qty#1055960,demandChannel#1055961,demandStream#1055962,kpis#1055963]"]; } 231 [id="node231" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686267]"]; subgraph cluster232 { isCluster="true"; id="cluster232"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 233 [id="node233" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1011816L) AND isnotnull(shardId#1011815))"]; } 234 [id="node234" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822], [isnotnull(worklistShardItemId#1011816L), isnotnull(shardId#1011815)]"]; 235 [id="node235" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster236 { isCluster="true"; id="cluster236"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 237 [id="node237" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster241 { isCluster="true"; id="cluster241"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 242 [id="node242" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1055975L ASC NULLS FIRST, cachedShardId#1055974 ASC NULLS FIRST], false, 0"]; } 243 [id="node243" 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#1055975L, cachedShardId#1055974, 37), ENSURE_REQUIREMENTS, [plan_id=1686283]"]; subgraph cluster244 { isCluster="true"; id="cluster244"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 245 [id="node245" labelType="html" label=" Project " tooltip="Project [shardId#1055968 AS cachedShardId#1055974, worklistShardItemId#1055969L AS cachedWorklistShardItemId#1055975L, qty#1055970 AS cachedQty#1055976, demandChannel#1055971, demandStream#1055972, kpis#1055973 AS cachedKpis#1055977]"]; 246 [id="node246" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055969L) AND isnotnull(shardId#1055968))"]; 247 [id="node247" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055968,worklistShardItemId#1055969L,qty#1055970,demandChannel#1055971,demandStream#1055972,kpis#1055973]"]; } 248 [id="node248" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 1 ms time to collect: 572 ms number of output rows: 7 data size: 2.0 MiB" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, true], input[1, bigint, true]),false), [plan_id=1687368]"]; subgraph cluster249 { isCluster="true"; id="cluster249"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n44 ms (0 ms, 0 ms, 5 ms (stage 110126.0: task 363876))"; tooltip="WholeStageCodegen (4)"; 250 [id="node250" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 25 ms (0 ms, 0 ms, 4 ms (stage 110126.0: task 363876)) peak memory total (min, med, max (stageId: taskId)) 23.3 MiB (256.0 KiB, 256.0 KiB, 2.3 MiB (stage 110126.0: task 363866)) number of output rows: 7 number of sort fallback tasks: 0 avg hash probes per key (min, med, max (stageId: taskId)): (1, 1, 1 (stage 110126.0: task 363866))" tooltip="HashAggregate(keys=[shardId#1059677, worklistShardItemId#1059678L], functions=[max(version#1059679)])"]; } 251 [id="node251" labelType="html" label="Exchange shuffle records written: 17 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 17 local bytes read total (min, med, max (stageId: taskId)) 1000.0 B (99.0 B, 101.0 B, 200.0 B (stage 110126.0: task 363866)) merged fetch fallback count: 0 local blocks read: 10 remote merged chunks fetched: 0 remote blocks read: 7 data size total (min, med, max (stageId: taskId)) 816.0 B (48.0 B, 48.0 B, 96.0 B (stage 110125.0: task 363806)) local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 8 ms (0 ms, 0 ms, 0 ms (stage 110125.0: task 363819)) 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)) 3 ms (0 ms, 0 ms, 3 ms (stage 110126.0: task 363863)) remote bytes read total (min, med, max (stageId: taskId)) 702.0 B (99.0 B, 300.0 B, 303.0 B (stage 110126.0: task 363867)) number of partitions: 37 remote reqs duration total (min, med, max (stageId: taskId)) 13 ms (3 ms, 4 ms, 6 ms (stage 110126.0: task 363862)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 1702.0 B (99.0 B, 100.0 B, 201.0 B (stage 110125.0: task 363806))" tooltip="Exchange hashpartitioning(shardId#1059677, worklistShardItemId#1059678L, 37), ENSURE_REQUIREMENTS, [plan_id=1687364]"]; subgraph cluster252 { isCluster="true"; id="cluster252"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n1.1 s (0 ms, 1 ms, 100 ms (stage 110125.0: task 363794))"; tooltip="WholeStageCodegen (3)"; 253 [id="node253" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 31 ms (0 ms, 0 ms, 7 ms (stage 110125.0: task 363794)) peak memory total (min, med, max (stageId: taskId)) 18.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 110125.0: task 363789)) number of output rows: 17 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#1059677, worklistShardItemId#1059678L], functions=[partial_max(version#1059679)])"]; 254 [id="node254" labelType="html" label="Filter number of output rows: 17" tooltip="Filter (isnotnull(shardId#1059677) AND isnotnull(worklistShardItemId#1059678L))"]; } 255 [id="node255" labelType="html" label="InMemoryTableScan number of output rows: 17" tooltip="InMemoryTableScan [shardId#1059677, worklistShardItemId#1059678L, version#1059679], [isnotnull(shardId#1059677), isnotnull(worklistShardItemId#1059678L)]"]; 256 [id="node256" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster257 { isCluster="true"; id="cluster257"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 258 [id="node258" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1056211, null AS demandStream#1056212, [] AS kpis#1056246, true AS isNewlyCalculated#1056214]"]; 259 [id="node259" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978)], LeftAnti"]; } subgraph cluster260 { isCluster="true"; id="cluster260"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 261 [id="node261" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1011815, ) ASC NULLS FIRST, isnull(shardId#1011815) ASC NULLS FIRST, coalesce(worklistShardItemId#1011816L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1011816L) ASC NULLS FIRST, coalesce(version#1011817, 0) ASC NULLS FIRST, isnull(version#1011817) ASC NULLS FIRST, coalesce(product#1011818, ) ASC NULLS FIRST, isnull(product#1011818) ASC NULLS FIRST, coalesce(plant#1011819, ) ASC NULLS FIRST, isnull(plant#1011819) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))) ASC NULLS FIRST, isnull(qty#1011822) ASC NULLS FIRST], false, 0"]; } 262 [id="node262" 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#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822), 37), ENSURE_REQUIREMENTS, [plan_id=1686389]"]; 263 [id="node263" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]"]; 264 [id="node264" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster265 { isCluster="true"; id="cluster265"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 266 [id="node266" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster267 { isCluster="true"; id="cluster267"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 268 [id="node268" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1056203, ) ASC NULLS FIRST, isnull(shardId#1056203) ASC NULLS FIRST, coalesce(worklistShardItemId#1056204L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1056204L) ASC NULLS FIRST, coalesce(version#1056205, 0) ASC NULLS FIRST, isnull(version#1056205) ASC NULLS FIRST, coalesce(product#1056206, ) ASC NULLS FIRST, isnull(product#1056206) ASC NULLS FIRST, coalesce(plant#1056207, ) ASC NULLS FIRST, isnull(plant#1056207) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))) ASC NULLS FIRST, isnull(qty#1055978) ASC NULLS FIRST], false, 0"]; } 269 [id="node269" 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#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978), 37), ENSURE_REQUIREMENTS, [plan_id=1686409]"]; 270 [id="node270" labelType="html" label=" Union " tooltip="Union"]; 271 [id="node271" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978]"]; subgraph cluster272 { isCluster="true"; id="cluster272"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 273 [id="node273" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]"]; 274 [id="node274" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], Inner"]; } subgraph cluster275 { isCluster="true"; id="cluster275"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 276 [id="node276" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0"]; } 277 [id="node277" 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#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]"]; subgraph cluster278 { isCluster="true"; id="cluster278"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 279 [id="node279" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; } 280 [id="node280" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1686273]"]; subgraph cluster281 { isCluster="true"; id="cluster281"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 282 [id="node282" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; 283 [id="node283" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]"]; 284 [id="node284" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055965L, cachedShardId#1055964], Inner, BuildLeft, ((qty#1011822 = cachedQty#1055966) OR isnull(qty#1011822)), false"]; 292 [id="node292" labelType="html" label=" Project " tooltip="Project [shardId#1055958 AS cachedShardId#1055964, worklistShardItemId#1055959L AS cachedWorklistShardItemId#1055965L, qty#1055960 AS cachedQty#1055966]"]; 293 [id="node293" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055959L) AND isnotnull(shardId#1055958))"]; 294 [id="node294" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055958,worklistShardItemId#1055959L,qty#1055960,demandChannel#1055961,demandStream#1055962,kpis#1055963]"]; } 285 [id="node285" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686267]"]; subgraph cluster286 { isCluster="true"; id="cluster286"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 287 [id="node287" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1011816L) AND isnotnull(shardId#1011815))"]; } 288 [id="node288" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822], [isnotnull(worklistShardItemId#1011816L), isnotnull(shardId#1011815)]"]; 289 [id="node289" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster290 { isCluster="true"; id="cluster290"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 291 [id="node291" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster295 { isCluster="true"; id="cluster295"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 296 [id="node296" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1055975L ASC NULLS FIRST, cachedShardId#1055974 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(cachedWorklistShardItemId#1055975L, cachedShardId#1055974, 37), ENSURE_REQUIREMENTS, [plan_id=1686283]"]; subgraph cluster298 { isCluster="true"; id="cluster298"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 299 [id="node299" labelType="html" label=" Project " tooltip="Project [shardId#1055968 AS cachedShardId#1055974, worklistShardItemId#1055969L AS cachedWorklistShardItemId#1055975L, qty#1055970 AS cachedQty#1055976, demandChannel#1055971, demandStream#1055972, kpis#1055973 AS cachedKpis#1055977]"]; 300 [id="node300" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055969L) AND isnotnull(shardId#1055968))"]; 301 [id="node301" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055968,worklistShardItemId#1055969L,qty#1055970,demandChannel#1055971,demandStream#1055972,kpis#1055973]"]; } subgraph cluster302 { isCluster="true"; id="cluster302"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 303 [id="node303" labelType="html" label=" Project " tooltip="Project [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192]"]; 304 [id="node304" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1056186L, shardId#1056185], [cachedWorklistShardItemId#1056200L, cachedShardId#1056199], Inner, BuildLeft, false"]; 312 [id="node312" labelType="html" label=" Project " tooltip="Project [shardId#1056193 AS cachedShardId#1056199, worklistShardItemId#1056194L AS cachedWorklistShardItemId#1056200L]"]; 313 [id="node313" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1056194L) AND isnotnull(shardId#1056193))"]; 314 [id="node314" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1056193,worklistShardItemId#1056194L,qty#1056195,demandChannel#1056196,demandStream#1056197,kpis#1056198]"]; } 305 [id="node305" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686403]"]; subgraph cluster306 { isCluster="true"; id="cluster306"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 307 [id="node307" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#1056192) AND isnotnull(worklistShardItemId#1056186L)) AND isnotnull(shardId#1056185))"]; } 308 [id="node308" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192], [isnull(qty#1056192), isnotnull(worklistShardItemId#1056186L), isnotnull(shardId#1056185)]"]; 309 [id="node309" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster310 { isCluster="true"; id="cluster310"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 311 [id="node311" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster315 { isCluster="true"; id="cluster315"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 316 [id="node316" labelType="html" label=" Project " tooltip="Project [shardId#1056216, worklistShardItemId#1056217L, version#1056218, product#1056219, plant#1056220, qty#1056244, demandChannel#1056237, demandStream#1056238, kpis#1056245, false AS isNewlyCalculated#1056215]"]; } 317 [id="node317" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1056237, demandStream#1056238, kpis#1056245, plant#1056220, product#1056219, qty#1056244, shardId#1056216, version#1056218, worklistShardItemId#1056217L]"]; subgraph cluster318 { isCluster="true"; id="cluster318"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 319 [id="node319" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]"]; 320 [id="node320" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], Inner"]; } subgraph cluster321 { isCluster="true"; id="cluster321"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 322 [id="node322" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0"]; } 323 [id="node323" 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#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]"]; subgraph cluster324 { isCluster="true"; id="cluster324"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 325 [id="node325" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; } 326 [id="node326" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1686273]"]; subgraph cluster327 { isCluster="true"; id="cluster327"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 328 [id="node328" 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#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[])"]; 329 [id="node329" labelType="html" label=" Project " tooltip="Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]"]; 330 [id="node330" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055965L, cachedShardId#1055964], Inner, BuildLeft, ((qty#1011822 = cachedQty#1055966) OR isnull(qty#1011822)), false"]; 338 [id="node338" labelType="html" label=" Project " tooltip="Project [shardId#1055958 AS cachedShardId#1055964, worklistShardItemId#1055959L AS cachedWorklistShardItemId#1055965L, qty#1055960 AS cachedQty#1055966]"]; 339 [id="node339" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055959L) AND isnotnull(shardId#1055958))"]; 340 [id="node340" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055958,worklistShardItemId#1055959L,qty#1055960,demandChannel#1055961,demandStream#1055962,kpis#1055963]"]; } 331 [id="node331" labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 0 ms time to collect: 0 ms number of output rows: 0 data size: 0.0 B" tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686267]"]; subgraph cluster332 { isCluster="true"; id="cluster332"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 333 [id="node333" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1011816L) AND isnotnull(shardId#1011815))"]; } 334 [id="node334" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822], [isnotnull(worklistShardItemId#1011816L), isnotnull(shardId#1011815)]"]; 335 [id="node335" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]"]; subgraph cluster336 { isCluster="true"; id="cluster336"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 337 [id="node337" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1011815,worklistShardItemId#1011816L,version#1011817,product#1011818,plant#1011819,periodStart#1011820,periodEnd#1011821,qty#1011822]"]; } subgraph cluster341 { isCluster="true"; id="cluster341"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 342 [id="node342" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1055975L ASC NULLS FIRST, cachedShardId#1055974 ASC NULLS FIRST], false, 0"]; } 343 [id="node343" 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#1055975L, cachedShardId#1055974, 37), ENSURE_REQUIREMENTS, [plan_id=1686283]"]; subgraph cluster344 { isCluster="true"; id="cluster344"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 345 [id="node345" labelType="html" label=" Project " tooltip="Project [shardId#1055968 AS cachedShardId#1055974, worklistShardItemId#1055969L AS cachedWorklistShardItemId#1055975L, qty#1055970 AS cachedQty#1055976, demandChannel#1055971, demandStream#1055972, kpis#1055973 AS cachedKpis#1055977]"]; 346 [id="node346" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1055969L) AND isnotnull(shardId#1055968))"]; 347 [id="node347" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1055968,worklistShardItemId#1055969L,qty#1055970,demandChannel#1055971,demandStream#1055972,kpis#1055973]"]; } 1->0; 3->1; 4->3; 5->4; 7->5; 8->7; 9->8; 10->9; 12->10; 13->12; 15->13; 16->15; 17->16; 18->17; 20->18; 22->13; 23->22; 24->23; 25->24; 27->25; 28->27; 30->28; 31->30; 33->31; 34->33; 36->34; 37->36; 38->37; 39->38; 41->39; 42->41; 43->42; 45->43; 46->38; 47->46; 48->47; 50->28; 51->50; 53->51; 54->53; 55->54; 57->24; 58->57; 59->58; 61->59; 62->61; 63->62; 65->63; 66->58; 67->66; 68->67; 70->10; 71->70; 73->71; 74->73; 76->74; 77->76; 79->77; 80->79; 82->80; 83->82; 84->83; 85->84; 87->85; 88->87; 89->88; 91->89; 92->84; 93->92; 94->93; 96->74; 97->96; 99->97; 100->99; 101->100; 103->5; 104->103; 105->104; 107->105; 108->107; 109->108; 111->109; 112->111; 113->112; 114->113; 115->114; 116->115; 118->116; 119->118; 120->119; 121->120; 122->121; 123->114; 125->123; 126->125; 127->126; 128->127; 130->128; 131->130; 132->131; 133->132; 134->133; 135->114; 137->135; 138->137; 139->138; 140->139; 142->140; 143->142; 144->143; 145->144; 146->145; 147->113; 149->147; 150->149; 152->150; 153->152; 154->153; 155->154; 156->155; 158->156; 159->158; 161->159; 162->161; 163->162; 164->163; 166->164; 168->159; 169->168; 170->169; 171->170; 173->171; 174->173; 176->174; 177->176; 179->177; 180->179; 182->180; 183->182; 184->183; 185->184; 187->185; 188->187; 189->188; 191->189; 192->184; 193->192; 194->193; 196->174; 197->196; 199->197; 200->199; 201->200; 203->170; 204->203; 205->204; 207->205; 208->207; 209->208; 211->209; 212->204; 213->212; 214->213; 216->156; 217->216; 219->217; 220->219; 222->220; 223->222; 225->223; 226->225; 228->226; 229->228; 230->229; 231->230; 233->231; 234->233; 235->234; 237->235; 238->230; 239->238; 240->239; 242->220; 243->242; 245->243; 246->245; 247->246; 248->4; 250->248; 251->250; 253->251; 254->253; 255->254; 256->255; 258->256; 259->258; 261->259; 262->261; 263->262; 264->263; 266->264; 268->259; 269->268; 270->269; 271->270; 273->271; 274->273; 276->274; 277->276; 279->277; 280->279; 282->280; 283->282; 284->283; 285->284; 287->285; 288->287; 289->288; 291->289; 292->284; 293->292; 294->293; 296->274; 297->296; 299->297; 300->299; 301->300; 303->270; 304->303; 305->304; 307->305; 308->307; 309->308; 311->309; 312->304; 313->312; 314->313; 316->256; 317->316; 319->317; 320->319; 322->320; 323->322; 325->323; 326->325; 328->326; 329->328; 330->329; 331->330; 333->331; 334->333; 335->334; 337->335; 338->330; 339->338; 340->339; 342->320; 343->342; 345->343; 346->345; 347->346; }

Details

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


(1) InMemoryTableScan
Output: []

(2) InMemoryRelation
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1059580, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [7]: [demandChannel#1056211, demandStream#1056212, isNewlyCalculated#1056214, kpis#1056246, qty#1011822, shardId#1011815, worklistShardItemId#1011816L]
Arguments: [demandChannel#1056211, demandStream#1056212, isNewlyCalculated#1056214, kpis#1056246, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1056214, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]

(4) InMemoryRelation
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246, isNewlyCalculated#1056214], StorageLevel(disk, memory, 2 replicas)

(5) InMemoryTableScan
Output [6]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]

(6) InMemoryRelation
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, periodStart#1011820, periodEnd#1011821, qty#1011822], StorageLevel(disk, memory, 2 replicas)

(7) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, periodStart#1011820, periodEnd#1011821, qty#1011822]
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, periodStart#1011820, periodEnd#1011821, qty#1011822], SQLExecutionRDD[52639] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(8) Exchange
Input [8]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, periodStart#1011820, periodEnd#1011821, qty#1011822]
Arguments: hashpartitioning(product#1011818, plant#1011819, 37), REPARTITION_BY_NUM, [plan_id=1686159]

(9) Exchange
Input [6]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]
Arguments: hashpartitioning(coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822), 37), ENSURE_REQUIREMENTS, [plan_id=1686389]

(10) Sort [codegen id : 1]
Input [6]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]
Arguments: [coalesce(shardId#1011815, ) ASC NULLS FIRST, isnull(shardId#1011815) ASC NULLS FIRST, coalesce(worklistShardItemId#1011816L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1011816L) ASC NULLS FIRST, coalesce(version#1011817, 0) ASC NULLS FIRST, isnull(version#1011817) ASC NULLS FIRST, coalesce(product#1011818, ) ASC NULLS FIRST, isnull(product#1011818) ASC NULLS FIRST, coalesce(plant#1011819, ) ASC NULLS FIRST, isnull(plant#1011819) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))) ASC NULLS FIRST, isnull(qty#1011822) ASC NULLS FIRST], false, 0

(11) InMemoryTableScan
Output [6]: [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978]
Arguments: [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978]

(12) InMemoryRelation
Arguments: [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978, demandChannel#1055971, demandStream#1055972, kpis#1055979], StorageLevel(disk, memory, 2 replicas)

(13) InMemoryTableScan
Output [6]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822], [isnotnull(worklistShardItemId#1011816L), isnotnull(shardId#1011815)]

(14) InMemoryRelation
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, periodStart#1011820, periodEnd#1011821, qty#1011822], StorageLevel(disk, memory, 2 replicas)

(15) Filter [codegen id : 1]
Input [6]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]
Condition : (isnotnull(worklistShardItemId#1011816L) AND isnotnull(shardId#1011815))

(16) BroadcastExchange
Input [6]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686267]

(17) Scan ExistingRDD
Output [6]: [shardId#1055958, worklistShardItemId#1055959L, qty#1055960, demandChannel#1055961, demandStream#1055962, kpis#1055963]
Arguments: [shardId#1055958, worklistShardItemId#1055959L, qty#1055960, demandChannel#1055961, demandStream#1055962, kpis#1055963], MapPartitionsRDD[52661] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(18) Filter
Input [6]: [shardId#1055958, worklistShardItemId#1055959L, qty#1055960, demandChannel#1055961, demandStream#1055962, kpis#1055963]
Condition : (isnotnull(worklistShardItemId#1055959L) AND isnotnull(shardId#1055958))

(19) Project
Output [3]: [shardId#1055958 AS cachedShardId#1055964, worklistShardItemId#1055959L AS cachedWorklistShardItemId#1055965L, qty#1055960 AS cachedQty#1055966]
Input [6]: [shardId#1055958, worklistShardItemId#1055959L, qty#1055960, demandChannel#1055961, demandStream#1055962, kpis#1055963]

(20) BroadcastHashJoin [codegen id : 2]
Left keys [2]: [worklistShardItemId#1011816L, shardId#1011815]
Right keys [2]: [cachedWorklistShardItemId#1055965L, cachedShardId#1055964]
Join type: Inner
Join condition: ((qty#1011822 = cachedQty#1055966) OR isnull(qty#1011822))

(21) Project [codegen id : 2]
Output [5]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]
Input [9]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, cachedShardId#1055964, cachedWorklistShardItemId#1055965L, cachedQty#1055966]

(22) HashAggregate [codegen id : 2]
Input [5]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]
Keys [5]: [plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818]

(23) Exchange
Input [5]: [plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818]
Arguments: hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1686273]

(24) HashAggregate [codegen id : 3]
Input [5]: [plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818]
Keys [5]: [plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]

(25) Exchange
Input [5]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]
Arguments: hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]

(26) Sort [codegen id : 4]
Input [5]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819]
Arguments: [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0

(27) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#1055968, worklistShardItemId#1055969L, qty#1055970, demandChannel#1055971, demandStream#1055972, kpis#1055973]
Arguments: [shardId#1055968, worklistShardItemId#1055969L, qty#1055970, demandChannel#1055971, demandStream#1055972, kpis#1055973], MapPartitionsRDD[52661] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(28) Filter [codegen id : 5]
Input [6]: [shardId#1055968, worklistShardItemId#1055969L, qty#1055970, demandChannel#1055971, demandStream#1055972, kpis#1055973]
Condition : (isnotnull(worklistShardItemId#1055969L) AND isnotnull(shardId#1055968))

(29) Project [codegen id : 5]
Output [6]: [shardId#1055968 AS cachedShardId#1055974, worklistShardItemId#1055969L AS cachedWorklistShardItemId#1055975L, qty#1055970 AS cachedQty#1055976, demandChannel#1055971, demandStream#1055972, kpis#1055973 AS cachedKpis#1055977]
Input [6]: [shardId#1055968, worklistShardItemId#1055969L, qty#1055970, demandChannel#1055971, demandStream#1055972, kpis#1055973]

(30) Exchange
Input [6]: [cachedShardId#1055974, cachedWorklistShardItemId#1055975L, cachedQty#1055976, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977]
Arguments: hashpartitioning(cachedWorklistShardItemId#1055975L, cachedShardId#1055974, 37), ENSURE_REQUIREMENTS, [plan_id=1686283]

(31) Sort [codegen id : 6]
Input [6]: [cachedShardId#1055974, cachedWorklistShardItemId#1055975L, cachedQty#1055976, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977]
Arguments: [cachedWorklistShardItemId#1055975L ASC NULLS FIRST, cachedShardId#1055974 ASC NULLS FIRST], false, 0

(32) SortMergeJoin [codegen id : 7]
Left keys [2]: [worklistShardItemId#1011816L, shardId#1011815]
Right keys [2]: [cachedWorklistShardItemId#1055975L, cachedShardId#1055974]
Join type: Inner
Join condition: None

(33) Project [codegen id : 7]
Output [9]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]
Input [11]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedShardId#1055974, cachedWorklistShardItemId#1055975L, cachedQty#1055976, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977]

(34) InMemoryTableScan
Output [6]: [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192]
Arguments: [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192], [isnull(qty#1056192), isnotnull(worklistShardItemId#1056186L), isnotnull(shardId#1056185)]

(35) InMemoryRelation
Arguments: [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, periodStart#1056190, periodEnd#1056191, qty#1056192], StorageLevel(disk, memory, 2 replicas)

(36) Filter [codegen id : 2]
Input [6]: [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192]
Condition : ((isnull(qty#1056192) AND isnotnull(worklistShardItemId#1056186L)) AND isnotnull(shardId#1056185))

(37) BroadcastExchange
Input [6]: [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1686403]

(38) Scan ExistingRDD
Output [6]: [shardId#1056193, worklistShardItemId#1056194L, qty#1056195, demandChannel#1056196, demandStream#1056197, kpis#1056198]
Arguments: [shardId#1056193, worklistShardItemId#1056194L, qty#1056195, demandChannel#1056196, demandStream#1056197, kpis#1056198], MapPartitionsRDD[52661] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(39) Filter
Input [6]: [shardId#1056193, worklistShardItemId#1056194L, qty#1056195, demandChannel#1056196, demandStream#1056197, kpis#1056198]
Condition : (isnotnull(worklistShardItemId#1056194L) AND isnotnull(shardId#1056193))

(40) Project
Output [2]: [shardId#1056193 AS cachedShardId#1056199, worklistShardItemId#1056194L AS cachedWorklistShardItemId#1056200L]
Input [6]: [shardId#1056193, worklistShardItemId#1056194L, qty#1056195, demandChannel#1056196, demandStream#1056197, kpis#1056198]

(41) BroadcastHashJoin [codegen id : 3]
Left keys [2]: [worklistShardItemId#1056186L, shardId#1056185]
Right keys [2]: [cachedWorklistShardItemId#1056200L, cachedShardId#1056199]
Join type: Inner
Join condition: None

(42) Project [codegen id : 3]
Output [6]: [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192]
Input [8]: [shardId#1056185, worklistShardItemId#1056186L, version#1056187, product#1056188, plant#1056189, qty#1056192, cachedShardId#1056199, cachedWorklistShardItemId#1056200L]

(43) Union

(44) Exchange
Input [6]: [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978]
Arguments: hashpartitioning(coalesce(shardId#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978), 37), ENSURE_REQUIREMENTS, [plan_id=1686409]

(45) Sort [codegen id : 4]
Input [6]: [shardId#1056203, worklistShardItemId#1056204L, version#1056205, product#1056206, plant#1056207, qty#1055978]
Arguments: [coalesce(shardId#1056203, ) ASC NULLS FIRST, isnull(shardId#1056203) ASC NULLS FIRST, coalesce(worklistShardItemId#1056204L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1056204L) ASC NULLS FIRST, coalesce(version#1056205, 0) ASC NULLS FIRST, isnull(version#1056205) ASC NULLS FIRST, coalesce(product#1056206, ) ASC NULLS FIRST, isnull(product#1056206) ASC NULLS FIRST, coalesce(plant#1056207, ) ASC NULLS FIRST, isnull(plant#1056207) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))) ASC NULLS FIRST, isnull(qty#1055978) ASC NULLS FIRST], false, 0

(46) SortMergeJoin [codegen id : 5]
Left keys [12]: [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)]
Right keys [12]: [coalesce(shardId#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1055978, 0.0))), isnull(qty#1055978)]
Join type: LeftAnti
Join condition: None

(47) Project [codegen id : 5]
Output [10]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1056211, null AS demandStream#1056212, [] AS kpis#1056246, true AS isNewlyCalculated#1056214]
Input [6]: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822]

(48) InMemoryTableScan
Output [9]: [demandChannel#1056237, demandStream#1056238, kpis#1056245, plant#1056220, product#1056219, qty#1056244, shardId#1056216, version#1056218, worklistShardItemId#1056217L]
Arguments: [demandChannel#1056237, demandStream#1056238, kpis#1056245, plant#1056220, product#1056219, qty#1056244, shardId#1056216, version#1056218, worklistShardItemId#1056217L]

(49) InMemoryRelation
Arguments: [shardId#1056216, worklistShardItemId#1056217L, version#1056218, product#1056219, plant#1056220, qty#1056244, demandChannel#1056237, demandStream#1056238, kpis#1056245], StorageLevel(disk, memory, 2 replicas)

(50) Project [codegen id : 6]
Output [10]: [shardId#1056216, worklistShardItemId#1056217L, version#1056218, product#1056219, plant#1056220, qty#1056244, demandChannel#1056237, demandStream#1056238, kpis#1056245, false AS isNewlyCalculated#1056215]
Input [9]: [demandChannel#1056237, demandStream#1056238, kpis#1056245, plant#1056220, product#1056219, qty#1056244, shardId#1056216, version#1056218, worklistShardItemId#1056217L]

(51) Union

(52) Filter [codegen id : 1]
Input [7]: [demandChannel#1056211, demandStream#1056212, isNewlyCalculated#1056214, kpis#1056246, qty#1011822, shardId#1011815, worklistShardItemId#1011816L]
Condition : ((NOT isNewlyCalculated#1056214 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))

(53) Project [codegen id : 1]
Output [6]: [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246]
Input [7]: [demandChannel#1056211, demandStream#1056212, isNewlyCalculated#1056214, kpis#1056246, qty#1011822, shardId#1011815, worklistShardItemId#1011816L]

(54) InMemoryTableScan
Output [6]: [shardId#1059585, worklistShardItemId#1059586L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776]
Arguments: [shardId#1059585, worklistShardItemId#1059586L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776], [isnotnull(shardId#1059585), isnotnull(worklistShardItemId#1059586L)]

(55) InMemoryRelation
Arguments: [shardId#1059585, worklistShardItemId#1059586L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776], StorageLevel(disk, memory, 2 replicas)

(56) InMemoryTableScan
Output [1]: [prodPlantResults#1058721]
Arguments: [prodPlantResults#1058721]

(57) InMemoryRelation
Arguments: [prodPlantResults#1058721], StorageLevel(disk, memory, 2 replicas)

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

(59) SerializeFromObject [codegen id : 1]
Input [1]: [obj#1058710]
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#1058713, 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#1058714]

(60) Filter [codegen id : 1]
Input [2]: [performanceMeasurements#1058713, prodPlantResults#1058714]
Condition : ((size(prodPlantResults#1058714, true) > 0) AND isnotnull(prodPlantResults#1058714))

(61) Project [codegen id : 1]
Output [1]: [prodPlantResults#1058714]
Input [2]: [performanceMeasurements#1058713, prodPlantResults#1058714]

(62) Generate [codegen id : 1]
Input [1]: [prodPlantResults#1058714]
Arguments: explode(prodPlantResults#1058714), false, [prodPlantResults#1058721]

(63) Project
Output [6]: [prodPlantResults#1058721.productId AS product#1058740, prodPlantResults#1058721.plantId AS plant#1058741, null AS qty#1058767, null AS demandChannel#1058747, null AS demandStream#1058748, transform(prodPlantResults#1058721.kpiResults, lambdafunction(struct(label, lambda kpi#1058777.label, dateTime, lambda kpi#1058777.datetime, value, lambda kpi#1058777.value), lambda kpi#1058777, false)) AS kpis#1058776]
Input [1]: [prodPlantResults#1058721]

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

(65) InMemoryRelation
Arguments: [prodPlantResults#1058766], StorageLevel(disk, memory, 2 replicas)

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

(67) Project [codegen id : 1]
Output [3]: [prodPlantResults#1058766.productId AS _extract_productId#1058912, prodPlantResults#1058766.plantId AS _extract_plantId#1058913, prodPlantResults#1058766.quantityKpiResults AS _extract_quantityKpiResults#1058914]
Input [1]: [prodPlantResults#1058766]

(68) Generate [codegen id : 1]
Input [3]: [_extract_productId#1058912, _extract_plantId#1058913, _extract_quantityKpiResults#1058914]
Arguments: explode(_extract_quantityKpiResults#1058914), [_extract_productId#1058912, _extract_plantId#1058913], false, [quantityKpiResults#1058733]

(69) Project
Output [6]: [_extract_productId#1058912 AS product#1058727, _extract_plantId#1058913 AS plant#1058728, quantityKpiResults#1058733.quantity AS qty#1058734, null AS demandChannel#1058736, null AS demandStream#1058737, transform(quantityKpiResults#1058733.kpiResults, lambdafunction(struct(label, lambda kpi#1058777.label, dateTime, lambda kpi#1058777.datetime, value, lambda kpi#1058777.value), lambda kpi#1058777, false)) AS kpis#1058910]
Input [3]: [_extract_productId#1058912, _extract_plantId#1058913, quantityKpiResults#1058733]

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

(71) InMemoryRelation
Arguments: [prodPlantResults#1058771], StorageLevel(disk, memory, 2 replicas)

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

(73) Project [codegen id : 2]
Output [3]: [prodPlantResults#1058771.productId AS _extract_productId#1058915, prodPlantResults#1058771.plantId AS _extract_plantId#1058916, prodPlantResults#1058771.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1058917]
Input [1]: [prodPlantResults#1058771]

(74) Generate [codegen id : 2]
Input [3]: [_extract_productId#1058915, _extract_plantId#1058916, _extract_demandChannelStreamKpiResults#1058917]
Arguments: explode(_extract_demandChannelStreamKpiResults#1058917), [_extract_productId#1058915, _extract_plantId#1058916], false, [demandChannelStreamKpiResults#1058755]

(75) Project
Output [6]: [_extract_productId#1058915 AS product#1058749, _extract_plantId#1058916 AS plant#1058750, null AS qty#1058772, demandChannelStreamKpiResults#1058755.demandChannel AS demandChannel#1058757, demandChannelStreamKpiResults#1058755.demandStream AS demandStream#1058759, transform(demandChannelStreamKpiResults#1058755.kpiResults, lambdafunction(struct(label, lambda kpi#1058777.label, dateTime, lambda kpi#1058777.datetime, value, lambda kpi#1058777.value), lambda kpi#1058777, false)) AS kpis#1058911]
Input [3]: [_extract_productId#1058915, _extract_plantId#1058916, demandChannelStreamKpiResults#1058755]

(76) Union

(77) InMemoryTableScan
Output [6]: [isNewlyCalculated#1056214, plant#1011819, product#1011818, qty#1011822, shardId#1011815, worklistShardItemId#1011816L]
Arguments: [isNewlyCalculated#1056214, plant#1011819, product#1011818, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [isNewlyCalculated#1056214]

(78) InMemoryRelation
Arguments: [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246, isNewlyCalculated#1056214], StorageLevel(disk, memory, 2 replicas)

(79) Filter [codegen id : 3]
Input [6]: [isNewlyCalculated#1056214, plant#1011819, product#1011818, qty#1011822, shardId#1011815, worklistShardItemId#1011816L]
Condition : isNewlyCalculated#1056214

(80) Project [codegen id : 3]
Output [5]: [shardId#1011815, worklistShardItemId#1011816L, product#1011818, plant#1011819, qty#1011822]
Input [6]: [isNewlyCalculated#1056214, plant#1011819, product#1011818, qty#1011822, shardId#1011815, worklistShardItemId#1011816L]

(81) HashAggregate [codegen id : 3]
Input [5]: [shardId#1011815, worklistShardItemId#1011816L, product#1011818, plant#1011819, qty#1011822]
Keys [5]: [plant#1011819, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1011822)) AS qty#1011822, worklistShardItemId#1011816L, product#1011818]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#1011819, shardId#1011815, qty#1011822, worklistShardItemId#1011816L, product#1011818]

(82) Exchange
Input [5]: [plant#1011819, shardId#1011815, qty#1011822, worklistShardItemId#1011816L, product#1011818]
Arguments: hashpartitioning(plant#1011819, shardId#1011815, qty#1011822, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1687196]

(83) HashAggregate [codegen id : 4]
Input [5]: [plant#1011819, shardId#1011815, qty#1011822, worklistShardItemId#1011816L, product#1011818]
Keys [5]: [plant#1011819, shardId#1011815, qty#1011822, worklistShardItemId#1011816L, product#1011818]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#1011815, worklistShardItemId#1011816L, product#1011818, plant#1011819, qty#1011822]

(84) BroadcastExchange
Input [5]: [shardId#1011815, worklistShardItemId#1011816L, product#1011818, plant#1011819, qty#1011822]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, string, true], ), isnull(input[3, string, true])),false), [plan_id=1687200]

(85) BroadcastHashJoin [codegen id : 5]
Left keys [4]: [coalesce(product#1058740, ), isnull(product#1058740), coalesce(plant#1058741, ), isnull(plant#1058741)]
Right keys [4]: [coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819)]
Join type: Inner
Join condition: ((qty#1058767 <=> qty#1011822) OR isnull(qty#1011822))

(86) Project [codegen id : 5]
Output [6]: [shardId#1011815, worklistShardItemId#1011816L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776]
Input [11]: [product#1058740, plant#1058741, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776, shardId#1011815, worklistShardItemId#1011816L, product#1011818, plant#1011819, qty#1011822]

(87) Sort [codegen id : 5]
Input [6]: [shardId#1011815, worklistShardItemId#1011816L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776]
Arguments: [demandChannel#1058747 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#1058767)) AS qty#1058767 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1058748 ASC NULLS FIRST], false, 0

(88) SortAggregate
Input [6]: [shardId#1011815, worklistShardItemId#1011816L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776]
Keys [5]: [demandChannel#1058747, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1058767)) AS qty#1058767, worklistShardItemId#1011816L, demandStream#1058748]
Functions [1]: [partial_first(kpis#1058776, false)]
Aggregate Attributes [2]: [first#1058983, valueSet#1058984]
Results [7]: [demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748, first#1058985, valueSet#1058986]

(89) Exchange
Input [7]: [demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748, first#1058985, valueSet#1058986]
Arguments: hashpartitioning(demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748, 37), ENSURE_REQUIREMENTS, [plan_id=1687207]

(90) Sort [codegen id : 6]
Input [7]: [demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748, first#1058985, valueSet#1058986]
Arguments: [demandChannel#1058747 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1058767 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1058748 ASC NULLS FIRST], false, 0

(91) SortAggregate
Input [7]: [demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748, first#1058985, valueSet#1058986]
Keys [5]: [demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748]
Functions [1]: [first(kpis#1058776, false)]
Aggregate Attributes [1]: [first(kpis#1058776)()#1058908]
Results [6]: [shardId#1011815, worklistShardItemId#1011816L, qty#1058767, demandChannel#1058747, demandStream#1058748, first(kpis#1058776)()#1058908 AS kpis#1058909]

(92) Filter [codegen id : 2]
Input [6]: [shardId#1059585, worklistShardItemId#1059586L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058776]
Condition : (isnotnull(shardId#1059585) AND isnotnull(worklistShardItemId#1059586L))

(93) Union

(94) InMemoryTableScan
Output [3]: [shardId#1059677, worklistShardItemId#1059678L, version#1059679]
Arguments: [shardId#1059677, worklistShardItemId#1059678L, version#1059679], [isnotnull(shardId#1059677), isnotnull(worklistShardItemId#1059678L)]

(95) InMemoryRelation
Arguments: [shardId#1059677, worklistShardItemId#1059678L, version#1059679, product#1059680, plant#1059681, qty#1059684, demandChannel#1059733, demandStream#1059734, kpis#1059737, isNewlyCalculated#1059736], StorageLevel(disk, memory, 2 replicas)

(96) Filter [codegen id : 3]
Input [3]: [shardId#1059677, worklistShardItemId#1059678L, version#1059679]
Condition : (isnotnull(shardId#1059677) AND isnotnull(worklistShardItemId#1059678L))

(97) HashAggregate [codegen id : 3]
Input [3]: [shardId#1059677, worklistShardItemId#1059678L, version#1059679]
Keys [2]: [shardId#1059677, worklistShardItemId#1059678L]
Functions [1]: [partial_max(version#1059679)]
Aggregate Attributes [1]: [max#1060159]
Results [3]: [shardId#1059677, worklistShardItemId#1059678L, max#1060160]

(98) Exchange
Input [3]: [shardId#1059677, worklistShardItemId#1059678L, max#1060160]
Arguments: hashpartitioning(shardId#1059677, worklistShardItemId#1059678L, 37), ENSURE_REQUIREMENTS, [plan_id=1687364]

(99) HashAggregate [codegen id : 4]
Input [3]: [shardId#1059677, worklistShardItemId#1059678L, max#1060160]
Keys [2]: [shardId#1059677, worklistShardItemId#1059678L]
Functions [1]: [max(version#1059679)]
Aggregate Attributes [1]: [max(version#1059679)#1059584]
Results [3]: [shardId#1059677, worklistShardItemId#1059678L, (max(version#1059679)#1059584 + 1) AS version#1059580]

(100) BroadcastExchange
Input [3]: [shardId#1059677, worklistShardItemId#1059678L, version#1059580]
Arguments: HashedRelationBroadcastMode(List(input[0, string, true], input[1, bigint, true]),false), [plan_id=1687368]

(101) BroadcastHashJoin [codegen id : 5]
Left keys [2]: [shardId#1011815, worklistShardItemId#1011816L]
Right keys [2]: [shardId#1059677, worklistShardItemId#1059678L]
Join type: Inner
Join condition: None

(102) Project [codegen id : 5]
Output [7]: [shardId#1011815, worklistShardItemId#1011816L, version#1059580, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246]
Input [9]: [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246, shardId#1059677, worklistShardItemId#1059678L, version#1059580]

(103) CollectLimit
Input: []
Arguments: 1

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	6
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	4882f77d-cb97-36f6-9634-40c97ac3f47d
temporal.activity.type	RunStreamWithId