digraph G { id="graph_106367"; subgraph graph_stage_106367 { id="graph_stage_106367"; isCluster="true"; label="Stage 106367"; subgraph cluster_134167 { id="cluster_134167"; isCluster="true"; label="Exchange"; 51358 [id="node_51358" labelType="html" label="ShuffledRowRDD [51358] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134164 { id="cluster_134164"; isCluster="true"; label="WholeStageCodegen (1)"; 51359 [id="node_51359" labelType="html" label="MapPartitionsRDD [51359] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134187 { id="cluster_134187"; isCluster="true"; label="Exchange"; 51370 [id="node_51370" labelType="html" label="ShuffledRowRDD [51370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134184 { id="cluster_134184"; isCluster="true"; label="WholeStageCodegen (4)"; 51371 [id="node_51371" labelType="html" label="MapPartitionsRDD [51371] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134216 { id="cluster_134216"; isCluster="true"; label="Exchange"; 51374 [id="node_51374" labelType="html" label="ShuffledRowRDD [51374] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134213 { id="cluster_134213"; isCluster="true"; label="WholeStageCodegen (6)"; 51375 [id="node_51375" labelType="html" label="MapPartitionsRDD [51375] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134176 { id="cluster_134176"; isCluster="true"; label="WholeStageCodegen (7)"; 51376 [id="node_51376" labelType="html" label="ZippedPartitionsRDD2 [51376] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51377 [id="node_51377" labelType="html" label="MapPartitionsRDD [51377] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134175 { id="cluster_134175"; isCluster="true"; label="InMemoryTableScan"; 51378 [id="node_51378" labelType="html" label="MapPartitionsRDD [51378] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51379 [id="node_51379" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1028186 AS qty#1028188, demandChannel#1028181, demandStream#1028182, cachedKpis#1028187 AS kpis#1028189]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1028185L, cachedShardId#1028184], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1678424]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [51379] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134173 { id="cluster_134173"; isCluster="true"; label="Exchange"; 51386 [id="node_51386" labelType="html" label="ShuffledRowRDD [51386] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134170 { id="cluster_134170"; isCluster="true"; label="WholeStageCodegen (4)"; 51387 [id="node_51387" labelType="html" label="MapPartitionsRDD [51387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134156 { id="cluster_134156"; isCluster="true"; label="WholeStageCodegen (5)"; 51388 [id="node_51388" labelType="html" label="ZippedPartitionsRDD2 [51388] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51389 [id="node_51389" labelType="html" label="MapPartitionsRDD [51389] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134237 { id="cluster_134237"; isCluster="true"; label="InMemoryTableScan"; 51390 [id="node_51390" labelType="html" label="MapPartitionsRDD [51390] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51391 [id="node_51391" labelType="html" label="MapPartitionsRDD [51391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51392 [id="node_51392" labelType="html" label="MapPartitionsRDD [51392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134234 { id="cluster_134234"; isCluster="true"; label="WholeStageCodegen (6)"; 51393 [id="node_51393" labelType="html" label="MapPartitionsRDD [51393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134155 { id="cluster_134155"; isCluster="true"; label="Union"; 51394 [id="node_51394" labelType="html" label="UnionRDD [51394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134154 { id="cluster_134154"; isCluster="true"; label="InMemoryTableScan"; 51395 [id="node_51395" labelType="html" label="MapPartitionsRDD [51395] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51396 [id="node_51396" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1028421, null AS demandStream#1028422, [] AS kpis#1028456, true AS isNewlyCalculated#1028424]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1028413, ), isnull(shardId#1028413), coalesce(worklistShardItemId#1028414L, 0), isnull(worklistShardItemId#1028414L), coalesce(version#1028415, 0), isnull(version#1028415), coalesce(product#1028416, ), isnull(product#1028416), coalesce(plant#1028417, ), isnull(plant#1028417), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51396] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134444 { id="cluster_134444"; isCluster="true"; label="Exchange"; 51492 [id="node_51492" labelType="html" label="ShuffledRowRDD [51492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134438 { id="cluster_134438"; isCluster="true"; label="WholeStageCodegen (6)"; 51493 [id="node_51493" labelType="html" label="MapPartitionsRDD [51493] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134437 { id="cluster_134437"; isCluster="true"; label="SortAggregate"; 51494 [id="node_51494" labelType="html" label="MapPartitionsRDD [51494] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134436 { id="cluster_134436"; isCluster="true"; label="InMemoryTableScan"; 51495 [id="node_51495" labelType="html" label="MapPartitionsRDD [51495] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51496 [id="node_51496" labelType="html" label="SortAggregate(key=[demandChannel#1030957, shardId#1011815, qty#1030977, worklistShardItemId#1011816L, demandStream#1030958], functions=[first(kpis#1030986, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1030977, demandChannel#1030957, demandStream#1030958, kpis#1031119])\n+- *(6) Sort [demandChannel#1030957 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1030977 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1030958 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1030957, shardId#1011815, qty#1030977, worklistShardItemId#1011816L, demandStream#1030958, 37), ENSURE_REQUIREMENTS, [plan_id=1679354]\n +- SortAggregate(key=[demandChannel#1030957, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1030977)) AS qty#1030977, worklistShardItemId#1011816L, demandStream#1030958], functions=[partial_first(kpis#1030986, false)], output=[demandChannel#1030957, shardId#1011815, qty#1030977, worklistShardItemId#1011816L,... [51496] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134603 { id="cluster_134603"; isCluster="true"; label="InMemoryTableScan"; 51534 [id="node_51534" labelType="html" label="MapPartitionsRDD [51534] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51535 [id="node_51535" labelType="html" label="MapPartitionsRDD [51535] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51536 [id="node_51536" labelType="html" label="MapPartitionsRDD [51536] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134599 { id="cluster_134599"; isCluster="true"; label="WholeStageCodegen (1)"; 51537 [id="node_51537" labelType="html" label="MapPartitionsRDD [51537] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134607 { id="cluster_134607"; isCluster="true"; label="InMemoryTableScan"; 51538 [id="node_51538" labelType="html" label="MapPartitionsRDD [51538] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51539 [id="node_51539" labelType="html" label="MapPartitionsRDD [51539] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51540 [id="node_51540" labelType="html" label="MapPartitionsRDD [51540] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134604 { id="cluster_134604"; isCluster="true"; label="WholeStageCodegen (2)"; 51541 [id="node_51541" labelType="html" label="MapPartitionsRDD [51541] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134598 { id="cluster_134598"; isCluster="true"; label="Union"; 51542 [id="node_51542" labelType="html" label="UnionRDD [51542] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134574 { id="cluster_134574"; isCluster="true"; label="WholeStageCodegen (5)"; 51543 [id="node_51543" labelType="html" label="MapPartitionsRDD [51543] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134573 { id="cluster_134573"; isCluster="true"; label="InMemoryTableScan"; 51544 [id="node_51544" labelType="html" label="MapPartitionsRDD [51544] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51545 [id="node_51545" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1031790, qty#1011822, demandChannel#1028421, demandStream#1028422, kpis#1028456]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1031887, worklistShardItemId#1031888L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1028421, demandStream#1028422, kpis#1028456]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1028424 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1028421, demandStream#1028422, isNewlyCalculated#1028424, kpis#1028456, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1028424, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [51545] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134632 { id="cluster_134632"; isCluster="true"; label="InMemoryTableScan"; 51554 [id="node_51554" labelType="html" label="MapPartitionsRDD [51554] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51555 [id="node_51555" labelType="html" label="MapPartitionsRDD [51555] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51556 [id="node_51556" labelType="html" label="MapPartitionsRDD [51556] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51358->51359; 51370->51371; 51374->51375; 51371->51376; 51375->51376; 51376->51377; 51377->51378; 51378->51379; 51386->51387; 51359->51388; 51387->51388; 51388->51389; 51379->51390; 51390->51391; 51391->51392; 51392->51393; 51389->51394; 51393->51394; 51394->51395; 51395->51396; 51492->51493; 51493->51494; 51494->51495; 51495->51496; 51396->51534; 51534->51535; 51535->51536; 51536->51537; 51496->51538; 51538->51539; 51539->51540; 51540->51541; 51537->51542; 51541->51542; 51542->51543; 51543->51544; 51544->51545; 51545->51554; 51554->51555; 51555->51556; }