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

Submitted Time: 2026/03/21 01:13:21
Duration: 0.9 s
Succeeded Jobs: 6415

Plan Visualization

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

digraph G { 0 [id="node0" labelType="html" label="InMemoryTableScan number of output rows: 156" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]"]; subgraph cluster1 { isCluster="true"; id="cluster1"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 2 [id="node2" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]"]; 3 [id="node3" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1132145, worklistShardItemId#1132146L], Inner, BuildRight, false"]; } 4 [id="node4" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster5 { isCluster="true"; id="cluster5"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 6 [id="node6" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]"]; 7 [id="node7" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((NOT isNewlyCalculated#1128682 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))"]; } 8 [id="node8" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1128679, demandStream#1128680, isNewlyCalculated#1128682, kpis#1128714, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1128682, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]"]; 9 [id="node9" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster10 { isCluster="true"; id="cluster10"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 11 [id="node11" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1128679, null AS demandStream#1128680, [] AS kpis#1128714, true AS isNewlyCalculated#1128682]"]; 12 [id="node12" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446)], LeftAnti"]; } subgraph cluster13 { isCluster="true"; id="cluster13"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 14 [id="node14" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1100457, ) ASC NULLS FIRST, isnull(shardId#1100457) ASC NULLS FIRST, coalesce(worklistShardItemId#1100458L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1100458L) ASC NULLS FIRST, coalesce(version#1100459, 0) ASC NULLS FIRST, isnull(version#1100459) ASC NULLS FIRST, coalesce(product#1100460, ) ASC NULLS FIRST, isnull(product#1100460) ASC NULLS FIRST, coalesce(plant#1100461, ) ASC NULLS FIRST, isnull(plant#1100461) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))) ASC NULLS FIRST, isnull(qty#1100464) ASC NULLS FIRST], false, 0"]; } 15 [id="node15" 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#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464), 37), ENSURE_REQUIREMENTS, [plan_id=1755494]"]; 16 [id="node16" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]"]; 17 [id="node17" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster18 { isCluster="true"; id="cluster18"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 19 [id="node19" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster20 { isCluster="true"; id="cluster20"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 21 [id="node21" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1128671, ) ASC NULLS FIRST, isnull(shardId#1128671) ASC NULLS FIRST, coalesce(worklistShardItemId#1128672L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1128672L) ASC NULLS FIRST, coalesce(version#1128673, 0) ASC NULLS FIRST, isnull(version#1128673) ASC NULLS FIRST, coalesce(product#1128674, ) ASC NULLS FIRST, isnull(product#1128674) ASC NULLS FIRST, coalesce(plant#1128675, ) ASC NULLS FIRST, isnull(plant#1128675) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))) ASC NULLS FIRST, isnull(qty#1128446) ASC NULLS FIRST], false, 0"]; } 22 [id="node22" 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#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446), 37), ENSURE_REQUIREMENTS, [plan_id=1755514]"]; 23 [id="node23" labelType="html" label=" Union " tooltip="Union"]; 24 [id="node24" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446]"]; subgraph cluster25 { isCluster="true"; id="cluster25"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 26 [id="node26" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]"]; 27 [id="node27" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], Inner"]; } subgraph cluster28 { isCluster="true"; id="cluster28"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 29 [id="node29" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 30 [id="node30" 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#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]"]; subgraph cluster31 { isCluster="true"; id="cluster31"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 32 [id="node32" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 33 [id="node33" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1755378]"]; subgraph cluster34 { isCluster="true"; id="cluster34"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 35 [id="node35" labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 0.0 B number of output rows: 0 number of sort fallback tasks: 0 avg hash probes per key: 0" tooltip="HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 36 [id="node36" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 37 [id="node37" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128433L, cachedShardId#1128432], Inner, BuildLeft, ((qty#1100464 = cachedQty#1128434) OR isnull(qty#1100464)), false"]; 45 [id="node45" labelType="html" label=" Project " tooltip="Project [shardId#1128426 AS cachedShardId#1128432, worklistShardItemId#1128427L AS cachedWorklistShardItemId#1128433L, qty#1128428 AS cachedQty#1128434]"]; 46 [id="node46" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128427L) AND isnotnull(shardId#1128426))"]; 47 [id="node47" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128426,worklistShardItemId#1128427L,qty#1128428,demandChannel#1128429,demandStream#1128430,kpis#1128431]"]; } 38 [id="node38" 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=1755372]"]; subgraph cluster39 { isCluster="true"; id="cluster39"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 40 [id="node40" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 41 [id="node41" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 42 [id="node42" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster43 { isCluster="true"; id="cluster43"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 44 [id="node44" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster48 { isCluster="true"; id="cluster48"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 49 [id="node49" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1128443L ASC NULLS FIRST, cachedShardId#1128442 ASC NULLS FIRST], false, 0"]; } 50 [id="node50" 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#1128443L, cachedShardId#1128442, 37), ENSURE_REQUIREMENTS, [plan_id=1755388]"]; subgraph cluster51 { isCluster="true"; id="cluster51"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 52 [id="node52" labelType="html" label=" Project " tooltip="Project [shardId#1128436 AS cachedShardId#1128442, worklistShardItemId#1128437L AS cachedWorklistShardItemId#1128443L, qty#1128438 AS cachedQty#1128444, demandChannel#1128439, demandStream#1128440, kpis#1128441 AS cachedKpis#1128445]"]; 53 [id="node53" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128437L) AND isnotnull(shardId#1128436))"]; 54 [id="node54" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128436,worklistShardItemId#1128437L,qty#1128438,demandChannel#1128439,demandStream#1128440,kpis#1128441]"]; } subgraph cluster55 { isCluster="true"; id="cluster55"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 56 [id="node56" labelType="html" label=" Project " tooltip="Project [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660]"]; 57 [id="node57" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1128654L, shardId#1128653], [cachedWorklistShardItemId#1128668L, cachedShardId#1128667], Inner, BuildLeft, false"]; 65 [id="node65" labelType="html" label=" Project " tooltip="Project [shardId#1128661 AS cachedShardId#1128667, worklistShardItemId#1128662L AS cachedWorklistShardItemId#1128668L]"]; 66 [id="node66" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128662L) AND isnotnull(shardId#1128661))"]; 67 [id="node67" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128661,worklistShardItemId#1128662L,qty#1128663,demandChannel#1128664,demandStream#1128665,kpis#1128666]"]; } 58 [id="node58" 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=1755508]"]; subgraph cluster59 { isCluster="true"; id="cluster59"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 60 [id="node60" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#1128660) AND isnotnull(worklistShardItemId#1128654L)) AND isnotnull(shardId#1128653))"]; } 61 [id="node61" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660], [isnull(qty#1128660), isnotnull(worklistShardItemId#1128654L), isnotnull(shardId#1128653)]"]; 62 [id="node62" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster63 { isCluster="true"; id="cluster63"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 64 [id="node64" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster68 { isCluster="true"; id="cluster68"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 69 [id="node69" labelType="html" label=" Project " tooltip="Project [shardId#1128684, worklistShardItemId#1128685L, version#1128686, product#1128687, plant#1128688, qty#1128712, demandChannel#1128705, demandStream#1128706, kpis#1128713, false AS isNewlyCalculated#1128683]"]; } 70 [id="node70" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1128705, demandStream#1128706, kpis#1128713, plant#1128688, product#1128687, qty#1128712, shardId#1128684, version#1128686, worklistShardItemId#1128685L]"]; subgraph cluster71 { isCluster="true"; id="cluster71"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 72 [id="node72" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]"]; 73 [id="node73" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], Inner"]; } subgraph cluster74 { isCluster="true"; id="cluster74"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 75 [id="node75" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 76 [id="node76" 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#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]"]; subgraph cluster77 { isCluster="true"; id="cluster77"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 78 [id="node78" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 79 [id="node79" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1755378]"]; subgraph cluster80 { isCluster="true"; id="cluster80"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 81 [id="node81" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 82 [id="node82" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 83 [id="node83" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128433L, cachedShardId#1128432], Inner, BuildLeft, ((qty#1100464 = cachedQty#1128434) OR isnull(qty#1100464)), false"]; 91 [id="node91" labelType="html" label=" Project " tooltip="Project [shardId#1128426 AS cachedShardId#1128432, worklistShardItemId#1128427L AS cachedWorklistShardItemId#1128433L, qty#1128428 AS cachedQty#1128434]"]; 92 [id="node92" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128427L) AND isnotnull(shardId#1128426))"]; 93 [id="node93" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128426,worklistShardItemId#1128427L,qty#1128428,demandChannel#1128429,demandStream#1128430,kpis#1128431]"]; } 84 [id="node84" 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=1755372]"]; subgraph cluster85 { isCluster="true"; id="cluster85"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 86 [id="node86" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 87 [id="node87" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 88 [id="node88" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster89 { isCluster="true"; id="cluster89"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 90 [id="node90" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster94 { isCluster="true"; id="cluster94"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 95 [id="node95" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1128443L ASC NULLS FIRST, cachedShardId#1128442 ASC NULLS FIRST], false, 0"]; } 96 [id="node96" 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#1128443L, cachedShardId#1128442, 37), ENSURE_REQUIREMENTS, [plan_id=1755388]"]; subgraph cluster97 { isCluster="true"; id="cluster97"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 98 [id="node98" labelType="html" label=" Project " tooltip="Project [shardId#1128436 AS cachedShardId#1128442, worklistShardItemId#1128437L AS cachedWorklistShardItemId#1128443L, qty#1128438 AS cachedQty#1128444, demandChannel#1128439, demandStream#1128440, kpis#1128441 AS cachedKpis#1128445]"]; 99 [id="node99" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128437L) AND isnotnull(shardId#1128436))"]; 100 [id="node100" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128436,worklistShardItemId#1128437L,qty#1128438,demandChannel#1128439,demandStream#1128440,kpis#1128441]"]; } subgraph cluster101 { isCluster="true"; id="cluster101"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 102 [id="node102" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(shardId#1132053) AND isnotnull(worklistShardItemId#1132054L))"]; } 103 [id="node103" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1132053, worklistShardItemId#1132054L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244], [isnotnull(shardId#1132053), isnotnull(worklistShardItemId#1132054L)]"]; 104 [id="node104" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216], functions=[first(kpis#1131244, false)])"]; subgraph cluster105 { isCluster="true"; id="cluster105"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 106 [id="node106" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#1131215 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1131235 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1131216 ASC NULLS FIRST], false, 0"]; } 107 [id="node107" 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#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, 37), ENSURE_REQUIREMENTS, [plan_id=1756312]"]; 108 [id="node108" labelType="html" label="SortAggregate number of output rows: 0" tooltip="SortAggregate(key=[demandChannel#1131215, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1131235)) AS qty#1131235, worklistShardItemId#1100458L, demandStream#1131216], functions=[partial_first(kpis#1131244, false)])"]; subgraph cluster109 { isCluster="true"; id="cluster109"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 110 [id="node110" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [demandChannel#1131215 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#1131235)) AS qty#1131235 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1131216 ASC NULLS FIRST], false, 0"]; 111 [id="node111" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244]"]; 112 [id="node112" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [coalesce(product#1131208, ), isnull(product#1131208), coalesce(plant#1131209, ), isnull(plant#1131209)], [coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461)], Inner, BuildRight, ((qty#1131235 <=> qty#1100464) OR isnull(qty#1100464)), false"]; } 113 [id="node113" labelType="html" label=" Union " tooltip="Union"]; 114 [id="node114" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1131189.productId AS product#1131208, prodPlantResults#1131189.plantId AS plant#1131209, null AS qty#1131235, null AS demandChannel#1131215, null AS demandStream#1131216, transform(prodPlantResults#1131189.kpiResults, lambdafunction(struct(label, lambda kpi#1131245.label, dateTime, lambda kpi#1131245.datetime, value, lambda kpi#1131245.value), lambda kpi#1131245, false)) AS kpis#1131244]"]; 115 [id="node115" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1131189]"]; subgraph cluster116 { isCluster="true"; id="cluster116"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 117 [id="node117" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1131182), false, [prodPlantResults#1131189]"]; 118 [id="node118" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1131182]"]; 119 [id="node119" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1131182, true) > 0) AND isnotnull(prodPlantResults#1131182))"]; 120 [id="node120" 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#1131181, 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#1131182]"]; } 121 [id="node121" labelType="html" label=" Scan " tooltip="Scan[obj#1131178]"]; 122 [id="node122" labelType="html" label=" Project " tooltip="Project [_extract_productId#1131380 AS product#1131195, _extract_plantId#1131381 AS plant#1131196, quantityKpiResults#1131201.quantity AS qty#1131202, null AS demandChannel#1131204, null AS demandStream#1131205, transform(quantityKpiResults#1131201.kpiResults, lambdafunction(struct(label, lambda kpi#1131245.label, dateTime, lambda kpi#1131245.datetime, value, lambda kpi#1131245.value), lambda kpi#1131245, false)) AS kpis#1131378]"]; subgraph cluster123 { isCluster="true"; id="cluster123"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 124 [id="node124" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_quantityKpiResults#1131382), [_extract_productId#1131380, _extract_plantId#1131381], false, [quantityKpiResults#1131201]"]; 125 [id="node125" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1131234.productId AS _extract_productId#1131380, prodPlantResults#1131234.plantId AS _extract_plantId#1131381, prodPlantResults#1131234.quantityKpiResults AS _extract_quantityKpiResults#1131382]"]; 126 [id="node126" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#1131234.quantityKpiResults, true) > 0) AND isnotnull(prodPlantResults#1131234.quantityKpiResults))"]; } 127 [id="node127" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1131234], [(size(prodPlantResults#1131234.quantityKpiResults, true) > 0), isnotnull(prodPlantResults#1131234.quantityKpiResults)]"]; subgraph cluster128 { isCluster="true"; id="cluster128"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 129 [id="node129" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1131182), false, [prodPlantResults#1131189]"]; 130 [id="node130" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1131182]"]; 131 [id="node131" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1131182, true) > 0) AND isnotnull(prodPlantResults#1131182))"]; 132 [id="node132" 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#1131181, 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#1131182]"]; } 133 [id="node133" labelType="html" label=" Scan " tooltip="Scan[obj#1131178]"]; 134 [id="node134" labelType="html" label=" Project " tooltip="Project [_extract_productId#1131383 AS product#1131217, _extract_plantId#1131384 AS plant#1131218, null AS qty#1131240, demandChannelStreamKpiResults#1131223.demandChannel AS demandChannel#1131225, demandChannelStreamKpiResults#1131223.demandStream AS demandStream#1131227, transform(demandChannelStreamKpiResults#1131223.kpiResults, lambdafunction(struct(label, lambda kpi#1131245.label, dateTime, lambda kpi#1131245.datetime, value, lambda kpi#1131245.value), lambda kpi#1131245, false)) AS kpis#1131379]"]; subgraph cluster135 { isCluster="true"; id="cluster135"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 136 [id="node136" labelType="html" label="Generate number of output rows: 0" tooltip="Generate explode(_extract_demandChannelStreamKpiResults#1131385), [_extract_productId#1131383, _extract_plantId#1131384], false, [demandChannelStreamKpiResults#1131223]"]; 137 [id="node137" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1131239.productId AS _extract_productId#1131383, prodPlantResults#1131239.plantId AS _extract_plantId#1131384, prodPlantResults#1131239.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1131385]"]; 138 [id="node138" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((size(prodPlantResults#1131239.demandChannelStreamKpiResults, true) > 0) AND isnotnull(prodPlantResults#1131239.demandChannelStreamKpiResults))"]; } 139 [id="node139" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [prodPlantResults#1131239], [(size(prodPlantResults#1131239.demandChannelStreamKpiResults, true) > 0), isnotnull(prodPlantResults#1131239.demandChannelStreamKpiResults)]"]; subgraph cluster140 { isCluster="true"; id="cluster140"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 141 [id="node141" labelType="html" label=" Generate " tooltip="Generate explode(prodPlantResults#1131182), false, [prodPlantResults#1131189]"]; 142 [id="node142" labelType="html" label=" Project " tooltip="Project [prodPlantResults#1131182]"]; 143 [id="node143" labelType="html" label=" Filter " tooltip="Filter ((size(prodPlantResults#1131182, true) > 0) AND isnotnull(prodPlantResults#1131182))"]; 144 [id="node144" 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#1131181, 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#1131182]"]; } 145 [id="node145" labelType="html" label=" Scan " tooltip="Scan[obj#1131178]"]; 146 [id="node146" 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=1756305]"]; subgraph cluster147 { isCluster="true"; id="cluster147"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 148 [id="node148" 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#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 149 [id="node149" 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#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1756301]"]; subgraph cluster150 { isCluster="true"; id="cluster150"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 151 [id="node151" 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#1100461, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1100464)) AS qty#1100464, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 152 [id="node152" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]"]; 153 [id="node153" labelType="html" label="Filter number of output rows: 0" tooltip="Filter isNewlyCalculated#1128682: boolean"]; } 154 [id="node154" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [isNewlyCalculated#1128682, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [isNewlyCalculated#1128682]"]; 155 [id="node155" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster156 { isCluster="true"; id="cluster156"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 157 [id="node157" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1128679, null AS demandStream#1128680, [] AS kpis#1128714, true AS isNewlyCalculated#1128682]"]; 158 [id="node158" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446)], LeftAnti"]; } subgraph cluster159 { isCluster="true"; id="cluster159"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 160 [id="node160" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1100457, ) ASC NULLS FIRST, isnull(shardId#1100457) ASC NULLS FIRST, coalesce(worklistShardItemId#1100458L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1100458L) ASC NULLS FIRST, coalesce(version#1100459, 0) ASC NULLS FIRST, isnull(version#1100459) ASC NULLS FIRST, coalesce(product#1100460, ) ASC NULLS FIRST, isnull(product#1100460) ASC NULLS FIRST, coalesce(plant#1100461, ) ASC NULLS FIRST, isnull(plant#1100461) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))) ASC NULLS FIRST, isnull(qty#1100464) ASC NULLS FIRST], false, 0"]; } 161 [id="node161" 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#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464), 37), ENSURE_REQUIREMENTS, [plan_id=1755494]"]; 162 [id="node162" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]"]; 163 [id="node163" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster164 { isCluster="true"; id="cluster164"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 165 [id="node165" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster166 { isCluster="true"; id="cluster166"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 167 [id="node167" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1128671, ) ASC NULLS FIRST, isnull(shardId#1128671) ASC NULLS FIRST, coalesce(worklistShardItemId#1128672L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1128672L) ASC NULLS FIRST, coalesce(version#1128673, 0) ASC NULLS FIRST, isnull(version#1128673) ASC NULLS FIRST, coalesce(product#1128674, ) ASC NULLS FIRST, isnull(product#1128674) ASC NULLS FIRST, coalesce(plant#1128675, ) ASC NULLS FIRST, isnull(plant#1128675) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))) ASC NULLS FIRST, isnull(qty#1128446) ASC NULLS FIRST], false, 0"]; } 168 [id="node168" labelType="html" label="Exchange shuffle records written: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 0 local bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 data size: 0.0 B local merged bytes read: 0.0 B local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 fetch wait time: 0 ms remote bytes read: 0.0 B number of partitions: 0 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B" tooltip="Exchange hashpartitioning(coalesce(shardId#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446), 37), ENSURE_REQUIREMENTS, [plan_id=1755514]"]; 169 [id="node169" labelType="html" label=" Union " tooltip="Union"]; 170 [id="node170" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446]"]; subgraph cluster171 { isCluster="true"; id="cluster171"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 172 [id="node172" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]"]; 173 [id="node173" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], Inner"]; } subgraph cluster174 { isCluster="true"; id="cluster174"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 175 [id="node175" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 176 [id="node176" 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#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]"]; subgraph cluster177 { isCluster="true"; id="cluster177"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 178 [id="node178" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 179 [id="node179" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1755378]"]; subgraph cluster180 { isCluster="true"; id="cluster180"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 181 [id="node181" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 182 [id="node182" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 183 [id="node183" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128433L, cachedShardId#1128432], Inner, BuildLeft, ((qty#1100464 = cachedQty#1128434) OR isnull(qty#1100464)), false"]; 191 [id="node191" labelType="html" label=" Project " tooltip="Project [shardId#1128426 AS cachedShardId#1128432, worklistShardItemId#1128427L AS cachedWorklistShardItemId#1128433L, qty#1128428 AS cachedQty#1128434]"]; 192 [id="node192" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128427L) AND isnotnull(shardId#1128426))"]; 193 [id="node193" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128426,worklistShardItemId#1128427L,qty#1128428,demandChannel#1128429,demandStream#1128430,kpis#1128431]"]; } 184 [id="node184" 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=1755372]"]; subgraph cluster185 { isCluster="true"; id="cluster185"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 186 [id="node186" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 187 [id="node187" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 188 [id="node188" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster189 { isCluster="true"; id="cluster189"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 190 [id="node190" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster194 { isCluster="true"; id="cluster194"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 195 [id="node195" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1128443L ASC NULLS FIRST, cachedShardId#1128442 ASC NULLS FIRST], false, 0"]; } 196 [id="node196" 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#1128443L, cachedShardId#1128442, 37), ENSURE_REQUIREMENTS, [plan_id=1755388]"]; subgraph cluster197 { isCluster="true"; id="cluster197"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 198 [id="node198" labelType="html" label=" Project " tooltip="Project [shardId#1128436 AS cachedShardId#1128442, worklistShardItemId#1128437L AS cachedWorklistShardItemId#1128443L, qty#1128438 AS cachedQty#1128444, demandChannel#1128439, demandStream#1128440, kpis#1128441 AS cachedKpis#1128445]"]; 199 [id="node199" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128437L) AND isnotnull(shardId#1128436))"]; 200 [id="node200" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128436,worklistShardItemId#1128437L,qty#1128438,demandChannel#1128439,demandStream#1128440,kpis#1128441]"]; } subgraph cluster201 { isCluster="true"; id="cluster201"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 202 [id="node202" labelType="html" label=" Project " tooltip="Project [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660]"]; 203 [id="node203" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1128654L, shardId#1128653], [cachedWorklistShardItemId#1128668L, cachedShardId#1128667], Inner, BuildLeft, false"]; 211 [id="node211" labelType="html" label=" Project " tooltip="Project [shardId#1128661 AS cachedShardId#1128667, worklistShardItemId#1128662L AS cachedWorklistShardItemId#1128668L]"]; 212 [id="node212" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128662L) AND isnotnull(shardId#1128661))"]; 213 [id="node213" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128661,worklistShardItemId#1128662L,qty#1128663,demandChannel#1128664,demandStream#1128665,kpis#1128666]"]; } 204 [id="node204" 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=1755508]"]; subgraph cluster205 { isCluster="true"; id="cluster205"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 206 [id="node206" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#1128660) AND isnotnull(worklistShardItemId#1128654L)) AND isnotnull(shardId#1128653))"]; } 207 [id="node207" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660], [isnull(qty#1128660), isnotnull(worklistShardItemId#1128654L), isnotnull(shardId#1128653)]"]; 208 [id="node208" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster209 { isCluster="true"; id="cluster209"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 210 [id="node210" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster214 { isCluster="true"; id="cluster214"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 215 [id="node215" labelType="html" label=" Project " tooltip="Project [shardId#1128684, worklistShardItemId#1128685L, version#1128686, product#1128687, plant#1128688, qty#1128712, demandChannel#1128705, demandStream#1128706, kpis#1128713, false AS isNewlyCalculated#1128683]"]; } 216 [id="node216" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1128705, demandStream#1128706, kpis#1128713, plant#1128688, product#1128687, qty#1128712, shardId#1128684, version#1128686, worklistShardItemId#1128685L]"]; subgraph cluster217 { isCluster="true"; id="cluster217"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 218 [id="node218" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]"]; 219 [id="node219" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], Inner"]; } subgraph cluster220 { isCluster="true"; id="cluster220"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 221 [id="node221" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 222 [id="node222" 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#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]"]; subgraph cluster223 { isCluster="true"; id="cluster223"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 224 [id="node224" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 225 [id="node225" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1755378]"]; subgraph cluster226 { isCluster="true"; id="cluster226"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 227 [id="node227" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 228 [id="node228" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 229 [id="node229" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128433L, cachedShardId#1128432], Inner, BuildLeft, ((qty#1100464 = cachedQty#1128434) OR isnull(qty#1100464)), false"]; 237 [id="node237" labelType="html" label=" Project " tooltip="Project [shardId#1128426 AS cachedShardId#1128432, worklistShardItemId#1128427L AS cachedWorklistShardItemId#1128433L, qty#1128428 AS cachedQty#1128434]"]; 238 [id="node238" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128427L) AND isnotnull(shardId#1128426))"]; 239 [id="node239" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128426,worklistShardItemId#1128427L,qty#1128428,demandChannel#1128429,demandStream#1128430,kpis#1128431]"]; } 230 [id="node230" 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=1755372]"]; subgraph cluster231 { isCluster="true"; id="cluster231"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 232 [id="node232" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 233 [id="node233" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 234 [id="node234" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster235 { isCluster="true"; id="cluster235"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 236 [id="node236" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster240 { isCluster="true"; id="cluster240"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 241 [id="node241" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1128443L ASC NULLS FIRST, cachedShardId#1128442 ASC NULLS FIRST], false, 0"]; } 242 [id="node242" 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#1128443L, cachedShardId#1128442, 37), ENSURE_REQUIREMENTS, [plan_id=1755388]"]; subgraph cluster243 { isCluster="true"; id="cluster243"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 244 [id="node244" labelType="html" label=" Project " tooltip="Project [shardId#1128436 AS cachedShardId#1128442, worklistShardItemId#1128437L AS cachedWorklistShardItemId#1128443L, qty#1128438 AS cachedQty#1128444, demandChannel#1128439, demandStream#1128440, kpis#1128441 AS cachedKpis#1128445]"]; 245 [id="node245" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128437L) AND isnotnull(shardId#1128436))"]; 246 [id="node246" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128436,worklistShardItemId#1128437L,qty#1128438,demandChannel#1128439,demandStream#1128440,kpis#1128441]"]; } 247 [id="node247" labelType="html" label=" BroadcastExchange " tooltip="BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, true], input[1, bigint, true]),false), [plan_id=1756473]"]; subgraph cluster248 { isCluster="true"; id="cluster248"; label="WholeStageCodegen (4)"; tooltip="WholeStageCodegen (4)"; 249 [id="node249" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#1132145, worklistShardItemId#1132146L], functions=[max(version#1132147)])"]; } 250 [id="node250" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(shardId#1132145, worklistShardItemId#1132146L, 37), ENSURE_REQUIREMENTS, [plan_id=1756469]"]; subgraph cluster251 { isCluster="true"; id="cluster251"; label="WholeStageCodegen (3)"; tooltip="WholeStageCodegen (3)"; 252 [id="node252" labelType="html" label=" HashAggregate " tooltip="HashAggregate(keys=[shardId#1132145, worklistShardItemId#1132146L], functions=[partial_max(version#1132147)])"]; 253 [id="node253" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#1132145) AND isnotnull(worklistShardItemId#1132146L))"]; } 254 [id="node254" labelType="html" label=" InMemoryTableScan " tooltip="InMemoryTableScan [shardId#1132145, worklistShardItemId#1132146L, version#1132147], [isnotnull(shardId#1132145), isnotnull(worklistShardItemId#1132146L)]"]; 255 [id="node255" labelType="html" label=" Union " tooltip="Union"]; subgraph cluster256 { isCluster="true"; id="cluster256"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 257 [id="node257" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1128679, null AS demandStream#1128680, [] AS kpis#1128714, true AS isNewlyCalculated#1128682]"]; 258 [id="node258" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446)], LeftAnti"]; } subgraph cluster259 { isCluster="true"; id="cluster259"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 260 [id="node260" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1100457, ) ASC NULLS FIRST, isnull(shardId#1100457) ASC NULLS FIRST, coalesce(worklistShardItemId#1100458L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1100458L) ASC NULLS FIRST, coalesce(version#1100459, 0) ASC NULLS FIRST, isnull(version#1100459) ASC NULLS FIRST, coalesce(product#1100460, ) ASC NULLS FIRST, isnull(product#1100460) ASC NULLS FIRST, coalesce(plant#1100461, ) ASC NULLS FIRST, isnull(plant#1100461) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))) ASC NULLS FIRST, isnull(qty#1100464) ASC NULLS FIRST], false, 0"]; } 261 [id="node261" 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#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464), 37), ENSURE_REQUIREMENTS, [plan_id=1755494]"]; 262 [id="node262" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]"]; 263 [id="node263" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster264 { isCluster="true"; id="cluster264"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 265 [id="node265" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster266 { isCluster="true"; id="cluster266"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 267 [id="node267" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [coalesce(shardId#1128671, ) ASC NULLS FIRST, isnull(shardId#1128671) ASC NULLS FIRST, coalesce(worklistShardItemId#1128672L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1128672L) ASC NULLS FIRST, coalesce(version#1128673, 0) ASC NULLS FIRST, isnull(version#1128673) ASC NULLS FIRST, coalesce(product#1128674, ) ASC NULLS FIRST, isnull(product#1128674) ASC NULLS FIRST, coalesce(plant#1128675, ) ASC NULLS FIRST, isnull(plant#1128675) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))) ASC NULLS FIRST, isnull(qty#1128446) ASC NULLS FIRST], false, 0"]; } 268 [id="node268" 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#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446), 37), ENSURE_REQUIREMENTS, [plan_id=1755514]"]; 269 [id="node269" labelType="html" label=" Union " tooltip="Union"]; 270 [id="node270" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446]"]; subgraph cluster271 { isCluster="true"; id="cluster271"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 272 [id="node272" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]"]; 273 [id="node273" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], Inner"]; } subgraph cluster274 { isCluster="true"; id="cluster274"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 275 [id="node275" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 276 [id="node276" 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#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]"]; subgraph cluster277 { isCluster="true"; id="cluster277"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 278 [id="node278" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 279 [id="node279" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1755378]"]; subgraph cluster280 { isCluster="true"; id="cluster280"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 281 [id="node281" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 282 [id="node282" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 283 [id="node283" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128433L, cachedShardId#1128432], Inner, BuildLeft, ((qty#1100464 = cachedQty#1128434) OR isnull(qty#1100464)), false"]; 291 [id="node291" labelType="html" label=" Project " tooltip="Project [shardId#1128426 AS cachedShardId#1128432, worklistShardItemId#1128427L AS cachedWorklistShardItemId#1128433L, qty#1128428 AS cachedQty#1128434]"]; 292 [id="node292" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128427L) AND isnotnull(shardId#1128426))"]; 293 [id="node293" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128426,worklistShardItemId#1128427L,qty#1128428,demandChannel#1128429,demandStream#1128430,kpis#1128431]"]; } 284 [id="node284" 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=1755372]"]; subgraph cluster285 { isCluster="true"; id="cluster285"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 286 [id="node286" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 287 [id="node287" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 288 [id="node288" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster289 { isCluster="true"; id="cluster289"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 290 [id="node290" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster294 { isCluster="true"; id="cluster294"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 295 [id="node295" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1128443L ASC NULLS FIRST, cachedShardId#1128442 ASC NULLS FIRST], false, 0"]; } 296 [id="node296" 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#1128443L, cachedShardId#1128442, 37), ENSURE_REQUIREMENTS, [plan_id=1755388]"]; subgraph cluster297 { isCluster="true"; id="cluster297"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 298 [id="node298" labelType="html" label=" Project " tooltip="Project [shardId#1128436 AS cachedShardId#1128442, worklistShardItemId#1128437L AS cachedWorklistShardItemId#1128443L, qty#1128438 AS cachedQty#1128444, demandChannel#1128439, demandStream#1128440, kpis#1128441 AS cachedKpis#1128445]"]; 299 [id="node299" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128437L) AND isnotnull(shardId#1128436))"]; 300 [id="node300" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128436,worklistShardItemId#1128437L,qty#1128438,demandChannel#1128439,demandStream#1128440,kpis#1128441]"]; } subgraph cluster301 { isCluster="true"; id="cluster301"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 302 [id="node302" labelType="html" label=" Project " tooltip="Project [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660]"]; 303 [id="node303" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1128654L, shardId#1128653], [cachedWorklistShardItemId#1128668L, cachedShardId#1128667], Inner, BuildLeft, false"]; 311 [id="node311" labelType="html" label=" Project " tooltip="Project [shardId#1128661 AS cachedShardId#1128667, worklistShardItemId#1128662L AS cachedWorklistShardItemId#1128668L]"]; 312 [id="node312" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128662L) AND isnotnull(shardId#1128661))"]; 313 [id="node313" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128661,worklistShardItemId#1128662L,qty#1128663,demandChannel#1128664,demandStream#1128665,kpis#1128666]"]; } 304 [id="node304" 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=1755508]"]; subgraph cluster305 { isCluster="true"; id="cluster305"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 306 [id="node306" labelType="html" label="Filter number of output rows: 0" tooltip="Filter ((isnull(qty#1128660) AND isnotnull(worklistShardItemId#1128654L)) AND isnotnull(shardId#1128653))"]; } 307 [id="node307" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660], [isnull(qty#1128660), isnotnull(worklistShardItemId#1128654L), isnotnull(shardId#1128653)]"]; 308 [id="node308" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster309 { isCluster="true"; id="cluster309"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 310 [id="node310" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster314 { isCluster="true"; id="cluster314"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 315 [id="node315" labelType="html" label=" Project " tooltip="Project [shardId#1128684, worklistShardItemId#1128685L, version#1128686, product#1128687, plant#1128688, qty#1128712, demandChannel#1128705, demandStream#1128706, kpis#1128713, false AS isNewlyCalculated#1128683]"]; } 316 [id="node316" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [demandChannel#1128705, demandStream#1128706, kpis#1128713, plant#1128688, product#1128687, qty#1128712, shardId#1128684, version#1128686, worklistShardItemId#1128685L]"]; subgraph cluster317 { isCluster="true"; id="cluster317"; label="WholeStageCodegen (7)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (7)"; 318 [id="node318" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]"]; 319 [id="node319" labelType="html" label="SortMergeJoin number of output rows: 0 spill size: 0.0 B" tooltip="SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], Inner"]; } subgraph cluster320 { isCluster="true"; id="cluster320"; label="WholeStageCodegen (4)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (4)"; 321 [id="node321" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0"]; } 322 [id="node322" 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#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]"]; subgraph cluster323 { isCluster="true"; id="cluster323"; label="WholeStageCodegen (3)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (3)"; 324 [id="node324" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; } 325 [id="node325" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1755378]"]; subgraph cluster326 { isCluster="true"; id="cluster326"; label="WholeStageCodegen (2)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (2)"; 327 [id="node327" 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#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[])"]; 328 [id="node328" labelType="html" label=" Project " tooltip="Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]"]; 329 [id="node329" labelType="html" label="BroadcastHashJoin number of output rows: 0" tooltip="BroadcastHashJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128433L, cachedShardId#1128432], Inner, BuildLeft, ((qty#1100464 = cachedQty#1128434) OR isnull(qty#1100464)), false"]; 337 [id="node337" labelType="html" label=" Project " tooltip="Project [shardId#1128426 AS cachedShardId#1128432, worklistShardItemId#1128427L AS cachedWorklistShardItemId#1128433L, qty#1128428 AS cachedQty#1128434]"]; 338 [id="node338" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128427L) AND isnotnull(shardId#1128426))"]; 339 [id="node339" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128426,worklistShardItemId#1128427L,qty#1128428,demandChannel#1128429,demandStream#1128430,kpis#1128431]"]; } 330 [id="node330" 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=1755372]"]; subgraph cluster331 { isCluster="true"; id="cluster331"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (1)"; 332 [id="node332" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))"]; } 333 [id="node333" labelType="html" label="InMemoryTableScan number of output rows: 0" tooltip="InMemoryTableScan [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]"]; 334 [id="node334" labelType="html" label=" Exchange " tooltip="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]"]; subgraph cluster335 { isCluster="true"; id="cluster335"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 336 [id="node336" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]"]; } subgraph cluster340 { isCluster="true"; id="cluster340"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (6)"; 341 [id="node341" labelType="html" label="Sort sort time: 0 ms peak memory: 0.0 B spill size: 0.0 B" tooltip="Sort [cachedWorklistShardItemId#1128443L ASC NULLS FIRST, cachedShardId#1128442 ASC NULLS FIRST], false, 0"]; } 342 [id="node342" 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#1128443L, cachedShardId#1128442, 37), ENSURE_REQUIREMENTS, [plan_id=1755388]"]; subgraph cluster343 { isCluster="true"; id="cluster343"; label="WholeStageCodegen (5)\n \nduration: 0 ms"; tooltip="WholeStageCodegen (5)"; 344 [id="node344" labelType="html" label=" Project " tooltip="Project [shardId#1128436 AS cachedShardId#1128442, worklistShardItemId#1128437L AS cachedWorklistShardItemId#1128443L, qty#1128438 AS cachedQty#1128444, demandChannel#1128439, demandStream#1128440, kpis#1128441 AS cachedKpis#1128445]"]; 345 [id="node345" labelType="html" label="Filter number of output rows: 0" tooltip="Filter (isnotnull(worklistShardItemId#1128437L) AND isnotnull(shardId#1128436))"]; 346 [id="node346" labelType="html" label="Scan ExistingRDD number of output rows: 0" tooltip="Scan ExistingRDD[shardId#1128436,worklistShardItemId#1128437L,qty#1128438,demandChannel#1128439,demandStream#1128440,kpis#1128441]"]; } 2->0; 3->2; 4->3; 6->4; 7->6; 8->7; 9->8; 11->9; 12->11; 14->12; 15->14; 16->15; 17->16; 19->17; 21->12; 22->21; 23->22; 24->23; 26->24; 27->26; 29->27; 30->29; 32->30; 33->32; 35->33; 36->35; 37->36; 38->37; 40->38; 41->40; 42->41; 44->42; 45->37; 46->45; 47->46; 49->27; 50->49; 52->50; 53->52; 54->53; 56->23; 57->56; 58->57; 60->58; 61->60; 62->61; 64->62; 65->57; 66->65; 67->66; 69->9; 70->69; 72->70; 73->72; 75->73; 76->75; 78->76; 79->78; 81->79; 82->81; 83->82; 84->83; 86->84; 87->86; 88->87; 90->88; 91->83; 92->91; 93->92; 95->73; 96->95; 98->96; 99->98; 100->99; 102->4; 103->102; 104->103; 106->104; 107->106; 108->107; 110->108; 111->110; 112->111; 113->112; 114->113; 115->114; 117->115; 118->117; 119->118; 120->119; 121->120; 122->113; 124->122; 125->124; 126->125; 127->126; 129->127; 130->129; 131->130; 132->131; 133->132; 134->113; 136->134; 137->136; 138->137; 139->138; 141->139; 142->141; 143->142; 144->143; 145->144; 146->112; 148->146; 149->148; 151->149; 152->151; 153->152; 154->153; 155->154; 157->155; 158->157; 160->158; 161->160; 162->161; 163->162; 165->163; 167->158; 168->167; 169->168; 170->169; 172->170; 173->172; 175->173; 176->175; 178->176; 179->178; 181->179; 182->181; 183->182; 184->183; 186->184; 187->186; 188->187; 190->188; 191->183; 192->191; 193->192; 195->173; 196->195; 198->196; 199->198; 200->199; 202->169; 203->202; 204->203; 206->204; 207->206; 208->207; 210->208; 211->203; 212->211; 213->212; 215->155; 216->215; 218->216; 219->218; 221->219; 222->221; 224->222; 225->224; 227->225; 228->227; 229->228; 230->229; 232->230; 233->232; 234->233; 236->234; 237->229; 238->237; 239->238; 241->219; 242->241; 244->242; 245->244; 246->245; 247->3; 249->247; 250->249; 252->250; 253->252; 254->253; 255->254; 257->255; 258->257; 260->258; 261->260; 262->261; 263->262; 265->263; 267->258; 268->267; 269->268; 270->269; 272->270; 273->272; 275->273; 276->275; 278->276; 279->278; 281->279; 282->281; 283->282; 284->283; 286->284; 287->286; 288->287; 290->288; 291->283; 292->291; 293->292; 295->273; 296->295; 298->296; 299->298; 300->299; 302->269; 303->302; 304->303; 306->304; 307->306; 308->307; 310->308; 311->303; 312->311; 313->312; 315->255; 316->315; 318->316; 319->318; 321->319; 322->321; 324->322; 325->324; 327->325; 328->327; 329->328; 330->329; 332->330; 333->332; 334->333; 336->334; 337->329; 338->337; 339->338; 341->319; 342->341; 344->342; 345->344; 346->345; }

Details

== Physical Plan ==
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 [7]: [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]

(2) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714], StorageLevel(disk, memory, 2 replicas)

(3) InMemoryTableScan
Output [7]: [demandChannel#1128679, demandStream#1128680, isNewlyCalculated#1128682, kpis#1128714, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]
Arguments: [demandChannel#1128679, demandStream#1128680, isNewlyCalculated#1128682, kpis#1128714, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1128682, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]

(4) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714, isNewlyCalculated#1128682], StorageLevel(disk, memory, 2 replicas)

(5) InMemoryTableScan
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]

(6) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464], StorageLevel(disk, memory, 2 replicas)

(7) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464], SQLExecutionRDD[56160] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(8) Exchange
Input [8]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464]
Arguments: hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1755264]

(9) Exchange
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: hashpartitioning(coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464), 37), ENSURE_REQUIREMENTS, [plan_id=1755494]

(10) Sort [codegen id : 1]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: [coalesce(shardId#1100457, ) ASC NULLS FIRST, isnull(shardId#1100457) ASC NULLS FIRST, coalesce(worklistShardItemId#1100458L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1100458L) ASC NULLS FIRST, coalesce(version#1100459, 0) ASC NULLS FIRST, isnull(version#1100459) ASC NULLS FIRST, coalesce(product#1100460, ) ASC NULLS FIRST, isnull(product#1100460) ASC NULLS FIRST, coalesce(plant#1100461, ) ASC NULLS FIRST, isnull(plant#1100461) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))) ASC NULLS FIRST, isnull(qty#1100464) ASC NULLS FIRST], false, 0

(11) InMemoryTableScan
Output [6]: [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446]
Arguments: [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446]

(12) InMemoryRelation
Arguments: [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446, demandChannel#1128439, demandStream#1128440, kpis#1128447], StorageLevel(disk, memory, 2 replicas)

(13) InMemoryTableScan
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464], [isnotnull(worklistShardItemId#1100458L), isnotnull(shardId#1100457)]

(14) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, periodStart#1100462, periodEnd#1100463, qty#1100464], StorageLevel(disk, memory, 2 replicas)

(15) Filter [codegen id : 1]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Condition : (isnotnull(worklistShardItemId#1100458L) AND isnotnull(shardId#1100457))

(16) BroadcastExchange
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1755372]

(17) Scan ExistingRDD
Output [6]: [shardId#1128426, worklistShardItemId#1128427L, qty#1128428, demandChannel#1128429, demandStream#1128430, kpis#1128431]
Arguments: [shardId#1128426, worklistShardItemId#1128427L, qty#1128428, demandChannel#1128429, demandStream#1128430, kpis#1128431], MapPartitionsRDD[56182] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(18) Filter
Input [6]: [shardId#1128426, worklistShardItemId#1128427L, qty#1128428, demandChannel#1128429, demandStream#1128430, kpis#1128431]
Condition : (isnotnull(worklistShardItemId#1128427L) AND isnotnull(shardId#1128426))

(19) Project
Output [3]: [shardId#1128426 AS cachedShardId#1128432, worklistShardItemId#1128427L AS cachedWorklistShardItemId#1128433L, qty#1128428 AS cachedQty#1128434]
Input [6]: [shardId#1128426, worklistShardItemId#1128427L, qty#1128428, demandChannel#1128429, demandStream#1128430, kpis#1128431]

(20) BroadcastHashJoin [codegen id : 2]
Left keys [2]: [worklistShardItemId#1100458L, shardId#1100457]
Right keys [2]: [cachedWorklistShardItemId#1128433L, cachedShardId#1128432]
Join type: Inner
Join condition: ((qty#1100464 = cachedQty#1128434) OR isnull(qty#1100464))

(21) Project [codegen id : 2]
Output [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Input [9]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, cachedShardId#1128432, cachedWorklistShardItemId#1128433L, cachedQty#1128434]

(22) HashAggregate [codegen id : 2]
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Keys [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]

(23) Exchange
Input [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Arguments: hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1755378]

(24) HashAggregate [codegen id : 3]
Input [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Keys [5]: [plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]

(25) Exchange
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Arguments: hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1755382]

(26) Sort [codegen id : 4]
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461]
Arguments: [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0

(27) Scan ExistingRDD [codegen id : 5]
Output [6]: [shardId#1128436, worklistShardItemId#1128437L, qty#1128438, demandChannel#1128439, demandStream#1128440, kpis#1128441]
Arguments: [shardId#1128436, worklistShardItemId#1128437L, qty#1128438, demandChannel#1128439, demandStream#1128440, kpis#1128441], MapPartitionsRDD[56182] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(28) Filter [codegen id : 5]
Input [6]: [shardId#1128436, worklistShardItemId#1128437L, qty#1128438, demandChannel#1128439, demandStream#1128440, kpis#1128441]
Condition : (isnotnull(worklistShardItemId#1128437L) AND isnotnull(shardId#1128436))

(29) Project [codegen id : 5]
Output [6]: [shardId#1128436 AS cachedShardId#1128442, worklistShardItemId#1128437L AS cachedWorklistShardItemId#1128443L, qty#1128438 AS cachedQty#1128444, demandChannel#1128439, demandStream#1128440, kpis#1128441 AS cachedKpis#1128445]
Input [6]: [shardId#1128436, worklistShardItemId#1128437L, qty#1128438, demandChannel#1128439, demandStream#1128440, kpis#1128441]

(30) Exchange
Input [6]: [cachedShardId#1128442, cachedWorklistShardItemId#1128443L, cachedQty#1128444, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445]
Arguments: hashpartitioning(cachedWorklistShardItemId#1128443L, cachedShardId#1128442, 37), ENSURE_REQUIREMENTS, [plan_id=1755388]

(31) Sort [codegen id : 6]
Input [6]: [cachedShardId#1128442, cachedWorklistShardItemId#1128443L, cachedQty#1128444, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445]
Arguments: [cachedWorklistShardItemId#1128443L ASC NULLS FIRST, cachedShardId#1128442 ASC NULLS FIRST], false, 0

(32) SortMergeJoin [codegen id : 7]
Left keys [2]: [worklistShardItemId#1100458L, shardId#1100457]
Right keys [2]: [cachedWorklistShardItemId#1128443L, cachedShardId#1128442]
Join type: Inner
Join condition: None

(33) Project [codegen id : 7]
Output [9]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]
Input [11]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedShardId#1128442, cachedWorklistShardItemId#1128443L, cachedQty#1128444, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445]

(34) InMemoryTableScan
Output [6]: [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660]
Arguments: [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660], [isnull(qty#1128660), isnotnull(worklistShardItemId#1128654L), isnotnull(shardId#1128653)]

(35) InMemoryRelation
Arguments: [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, periodStart#1128658, periodEnd#1128659, qty#1128660], StorageLevel(disk, memory, 2 replicas)

(36) Filter [codegen id : 2]
Input [6]: [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660]
Condition : ((isnull(qty#1128660) AND isnotnull(worklistShardItemId#1128654L)) AND isnotnull(shardId#1128653))

(37) BroadcastExchange
Input [6]: [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, false], input[0, string, false]),false), [plan_id=1755508]

(38) Scan ExistingRDD
Output [6]: [shardId#1128661, worklistShardItemId#1128662L, qty#1128663, demandChannel#1128664, demandStream#1128665, kpis#1128666]
Arguments: [shardId#1128661, worklistShardItemId#1128662L, qty#1128663, demandChannel#1128664, demandStream#1128665, kpis#1128666], MapPartitionsRDD[56182] at start at FileStorageAdapterImpl.java:171, ExistingRDD, UnknownPartitioning(0)

(39) Filter
Input [6]: [shardId#1128661, worklistShardItemId#1128662L, qty#1128663, demandChannel#1128664, demandStream#1128665, kpis#1128666]
Condition : (isnotnull(worklistShardItemId#1128662L) AND isnotnull(shardId#1128661))

(40) Project
Output [2]: [shardId#1128661 AS cachedShardId#1128667, worklistShardItemId#1128662L AS cachedWorklistShardItemId#1128668L]
Input [6]: [shardId#1128661, worklistShardItemId#1128662L, qty#1128663, demandChannel#1128664, demandStream#1128665, kpis#1128666]

(41) BroadcastHashJoin [codegen id : 3]
Left keys [2]: [worklistShardItemId#1128654L, shardId#1128653]
Right keys [2]: [cachedWorklistShardItemId#1128668L, cachedShardId#1128667]
Join type: Inner
Join condition: None

(42) Project [codegen id : 3]
Output [6]: [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660]
Input [8]: [shardId#1128653, worklistShardItemId#1128654L, version#1128655, product#1128656, plant#1128657, qty#1128660, cachedShardId#1128667, cachedWorklistShardItemId#1128668L]

(43) Union

(44) Exchange
Input [6]: [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446]
Arguments: hashpartitioning(coalesce(shardId#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446), 37), ENSURE_REQUIREMENTS, [plan_id=1755514]

(45) Sort [codegen id : 4]
Input [6]: [shardId#1128671, worklistShardItemId#1128672L, version#1128673, product#1128674, plant#1128675, qty#1128446]
Arguments: [coalesce(shardId#1128671, ) ASC NULLS FIRST, isnull(shardId#1128671) ASC NULLS FIRST, coalesce(worklistShardItemId#1128672L, 0) ASC NULLS FIRST, isnull(worklistShardItemId#1128672L) ASC NULLS FIRST, coalesce(version#1128673, 0) ASC NULLS FIRST, isnull(version#1128673) ASC NULLS FIRST, coalesce(product#1128674, ) ASC NULLS FIRST, isnull(product#1128674) ASC NULLS FIRST, coalesce(plant#1128675, ) ASC NULLS FIRST, isnull(plant#1128675) ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))) ASC NULLS FIRST, isnull(qty#1128446) ASC NULLS FIRST], false, 0

(46) SortMergeJoin [codegen id : 5]
Left keys [12]: [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)]
Right keys [12]: [coalesce(shardId#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1128446, 0.0))), isnull(qty#1128446)]
Join type: LeftAnti
Join condition: None

(47) Project [codegen id : 5]
Output [10]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1128679, null AS demandStream#1128680, [] AS kpis#1128714, true AS isNewlyCalculated#1128682]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464]

(48) InMemoryTableScan
Output [9]: [demandChannel#1128705, demandStream#1128706, kpis#1128713, plant#1128688, product#1128687, qty#1128712, shardId#1128684, version#1128686, worklistShardItemId#1128685L]
Arguments: [demandChannel#1128705, demandStream#1128706, kpis#1128713, plant#1128688, product#1128687, qty#1128712, shardId#1128684, version#1128686, worklistShardItemId#1128685L]

(49) InMemoryRelation
Arguments: [shardId#1128684, worklistShardItemId#1128685L, version#1128686, product#1128687, plant#1128688, qty#1128712, demandChannel#1128705, demandStream#1128706, kpis#1128713], StorageLevel(disk, memory, 2 replicas)

(50) Project [codegen id : 6]
Output [10]: [shardId#1128684, worklistShardItemId#1128685L, version#1128686, product#1128687, plant#1128688, qty#1128712, demandChannel#1128705, demandStream#1128706, kpis#1128713, false AS isNewlyCalculated#1128683]
Input [9]: [demandChannel#1128705, demandStream#1128706, kpis#1128713, plant#1128688, product#1128687, qty#1128712, shardId#1128684, version#1128686, worklistShardItemId#1128685L]

(51) Union

(52) Filter [codegen id : 1]
Input [7]: [demandChannel#1128679, demandStream#1128680, isNewlyCalculated#1128682, kpis#1128714, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]
Condition : ((NOT isNewlyCalculated#1128682 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))

(53) Project [codegen id : 1]
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]
Input [7]: [demandChannel#1128679, demandStream#1128680, isNewlyCalculated#1128682, kpis#1128714, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]

(54) InMemoryTableScan
Output [6]: [shardId#1132053, worklistShardItemId#1132054L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244]
Arguments: [shardId#1132053, worklistShardItemId#1132054L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244], [isnotnull(shardId#1132053), isnotnull(worklistShardItemId#1132054L)]

(55) InMemoryRelation
Arguments: [shardId#1132053, worklistShardItemId#1132054L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244], StorageLevel(disk, memory, 2 replicas)

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

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

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

(59) SerializeFromObject [codegen id : 1]
Input [1]: [obj#1131178]
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#1131181, 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#1131182]

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

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

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

(63) Project
Output [6]: [prodPlantResults#1131189.productId AS product#1131208, prodPlantResults#1131189.plantId AS plant#1131209, null AS qty#1131235, null AS demandChannel#1131215, null AS demandStream#1131216, transform(prodPlantResults#1131189.kpiResults, lambdafunction(struct(label, lambda kpi#1131245.label, dateTime, lambda kpi#1131245.datetime, value, lambda kpi#1131245.value), lambda kpi#1131245, false)) AS kpis#1131244]
Input [1]: [prodPlantResults#1131189]

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

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

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

(67) Project [codegen id : 1]
Output [3]: [prodPlantResults#1131234.productId AS _extract_productId#1131380, prodPlantResults#1131234.plantId AS _extract_plantId#1131381, prodPlantResults#1131234.quantityKpiResults AS _extract_quantityKpiResults#1131382]
Input [1]: [prodPlantResults#1131234]

(68) Generate [codegen id : 1]
Input [3]: [_extract_productId#1131380, _extract_plantId#1131381, _extract_quantityKpiResults#1131382]
Arguments: explode(_extract_quantityKpiResults#1131382), [_extract_productId#1131380, _extract_plantId#1131381], false, [quantityKpiResults#1131201]

(69) Project
Output [6]: [_extract_productId#1131380 AS product#1131195, _extract_plantId#1131381 AS plant#1131196, quantityKpiResults#1131201.quantity AS qty#1131202, null AS demandChannel#1131204, null AS demandStream#1131205, transform(quantityKpiResults#1131201.kpiResults, lambdafunction(struct(label, lambda kpi#1131245.label, dateTime, lambda kpi#1131245.datetime, value, lambda kpi#1131245.value), lambda kpi#1131245, false)) AS kpis#1131378]
Input [3]: [_extract_productId#1131380, _extract_plantId#1131381, quantityKpiResults#1131201]

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

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

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

(73) Project [codegen id : 2]
Output [3]: [prodPlantResults#1131239.productId AS _extract_productId#1131383, prodPlantResults#1131239.plantId AS _extract_plantId#1131384, prodPlantResults#1131239.demandChannelStreamKpiResults AS _extract_demandChannelStreamKpiResults#1131385]
Input [1]: [prodPlantResults#1131239]

(74) Generate [codegen id : 2]
Input [3]: [_extract_productId#1131383, _extract_plantId#1131384, _extract_demandChannelStreamKpiResults#1131385]
Arguments: explode(_extract_demandChannelStreamKpiResults#1131385), [_extract_productId#1131383, _extract_plantId#1131384], false, [demandChannelStreamKpiResults#1131223]

(75) Project
Output [6]: [_extract_productId#1131383 AS product#1131217, _extract_plantId#1131384 AS plant#1131218, null AS qty#1131240, demandChannelStreamKpiResults#1131223.demandChannel AS demandChannel#1131225, demandChannelStreamKpiResults#1131223.demandStream AS demandStream#1131227, transform(demandChannelStreamKpiResults#1131223.kpiResults, lambdafunction(struct(label, lambda kpi#1131245.label, dateTime, lambda kpi#1131245.datetime, value, lambda kpi#1131245.value), lambda kpi#1131245, false)) AS kpis#1131379]
Input [3]: [_extract_productId#1131383, _extract_plantId#1131384, demandChannelStreamKpiResults#1131223]

(76) Union

(77) InMemoryTableScan
Output [6]: [isNewlyCalculated#1128682, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]
Arguments: [isNewlyCalculated#1128682, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [isNewlyCalculated#1128682]

(78) InMemoryRelation
Arguments: [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714, isNewlyCalculated#1128682], StorageLevel(disk, memory, 2 replicas)

(79) Filter [codegen id : 3]
Input [6]: [isNewlyCalculated#1128682, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]
Condition : isNewlyCalculated#1128682

(80) Project [codegen id : 3]
Output [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]
Input [6]: [isNewlyCalculated#1128682, plant#1100461, product#1100460, qty#1100464, shardId#1100457, worklistShardItemId#1100458L]

(81) HashAggregate [codegen id : 3]
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]
Keys [5]: [plant#1100461, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1100464)) AS qty#1100464, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]

(82) Exchange
Input [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]
Arguments: hashpartitioning(plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1756301]

(83) HashAggregate [codegen id : 4]
Input [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]
Keys [5]: [plant#1100461, shardId#1100457, qty#1100464, worklistShardItemId#1100458L, product#1100460]
Functions: []
Aggregate Attributes: []
Results [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]

(84) BroadcastExchange
Input [5]: [shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]
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=1756305]

(85) BroadcastHashJoin [codegen id : 5]
Left keys [4]: [coalesce(product#1131208, ), isnull(product#1131208), coalesce(plant#1131209, ), isnull(plant#1131209)]
Right keys [4]: [coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461)]
Join type: Inner
Join condition: ((qty#1131235 <=> qty#1100464) OR isnull(qty#1100464))

(86) Project [codegen id : 5]
Output [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244]
Input [11]: [product#1131208, plant#1131209, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244, shardId#1100457, worklistShardItemId#1100458L, product#1100460, plant#1100461, qty#1100464]

(87) Sort [codegen id : 5]
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244]
Arguments: [demandChannel#1131215 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, knownfloatingpointnormalized(normalizenanandzero(qty#1131235)) AS qty#1131235 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1131216 ASC NULLS FIRST], false, 0

(88) SortAggregate
Input [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244]
Keys [5]: [demandChannel#1131215, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1131235)) AS qty#1131235, worklistShardItemId#1100458L, demandStream#1131216]
Functions [1]: [partial_first(kpis#1131244, false)]
Aggregate Attributes [2]: [first#1131451, valueSet#1131452]
Results [7]: [demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, first#1131453, valueSet#1131454]

(89) Exchange
Input [7]: [demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, first#1131453, valueSet#1131454]
Arguments: hashpartitioning(demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, 37), ENSURE_REQUIREMENTS, [plan_id=1756312]

(90) Sort [codegen id : 6]
Input [7]: [demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, first#1131453, valueSet#1131454]
Arguments: [demandChannel#1131215 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1131235 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1131216 ASC NULLS FIRST], false, 0

(91) SortAggregate
Input [7]: [demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, first#1131453, valueSet#1131454]
Keys [5]: [demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216]
Functions [1]: [first(kpis#1131244, false)]
Aggregate Attributes [1]: [first(kpis#1131244)()#1131376]
Results [6]: [shardId#1100457, worklistShardItemId#1100458L, qty#1131235, demandChannel#1131215, demandStream#1131216, first(kpis#1131244)()#1131376 AS kpis#1131377]

(92) Filter [codegen id : 2]
Input [6]: [shardId#1132053, worklistShardItemId#1132054L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131244]
Condition : (isnotnull(shardId#1132053) AND isnotnull(worklistShardItemId#1132054L))

(93) Union

(94) InMemoryTableScan
Output [3]: [shardId#1132145, worklistShardItemId#1132146L, version#1132147]
Arguments: [shardId#1132145, worklistShardItemId#1132146L, version#1132147], [isnotnull(shardId#1132145), isnotnull(worklistShardItemId#1132146L)]

(95) InMemoryRelation
Arguments: [shardId#1132145, worklistShardItemId#1132146L, version#1132147, product#1132148, plant#1132149, qty#1132152, demandChannel#1132201, demandStream#1132202, kpis#1132205, isNewlyCalculated#1132204], StorageLevel(disk, memory, 2 replicas)

(96) Filter [codegen id : 3]
Input [3]: [shardId#1132145, worklistShardItemId#1132146L, version#1132147]
Condition : (isnotnull(shardId#1132145) AND isnotnull(worklistShardItemId#1132146L))

(97) HashAggregate [codegen id : 3]
Input [3]: [shardId#1132145, worklistShardItemId#1132146L, version#1132147]
Keys [2]: [shardId#1132145, worklistShardItemId#1132146L]
Functions [1]: [partial_max(version#1132147)]
Aggregate Attributes [1]: [max#1132627]
Results [3]: [shardId#1132145, worklistShardItemId#1132146L, max#1132628]

(98) Exchange
Input [3]: [shardId#1132145, worklistShardItemId#1132146L, max#1132628]
Arguments: hashpartitioning(shardId#1132145, worklistShardItemId#1132146L, 37), ENSURE_REQUIREMENTS, [plan_id=1756469]

(99) HashAggregate [codegen id : 4]
Input [3]: [shardId#1132145, worklistShardItemId#1132146L, max#1132628]
Keys [2]: [shardId#1132145, worklistShardItemId#1132146L]
Functions [1]: [max(version#1132147)]
Aggregate Attributes [1]: [max(version#1132147)#1132052]
Results [3]: [shardId#1132145, worklistShardItemId#1132146L, (max(version#1132147)#1132052 + 1) AS version#1132048]

(100) BroadcastExchange
Input [3]: [shardId#1132145, worklistShardItemId#1132146L, version#1132048]
Arguments: HashedRelationBroadcastMode(List(input[0, string, true], input[1, bigint, true]),false), [plan_id=1756473]

(101) BroadcastHashJoin [codegen id : 5]
Left keys [2]: [shardId#1100457, worklistShardItemId#1100458L]
Right keys [2]: [shardId#1132145, worklistShardItemId#1132146L]
Join type: Inner
Join condition: None

(102) Project [codegen id : 5]
Output [7]: [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]
Input [9]: [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714, shardId#1132145, worklistShardItemId#1132146L, version#1132048]

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	3
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	2fe7819b-828a-3eaa-98c4-d5f04113b6b3
temporal.activity.type	RunStreamWithId