digraph G { id="graph_112278"; subgraph graph_stage_112278 { id="graph_stage_112278"; isCluster="true"; label="Stage 112278"; subgraph cluster_139137 { id="cluster_139137"; isCluster="true"; label="Exchange"; 53472 [id="node_53472" labelType="html" label="ShuffledRowRDD [53472] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139134 { id="cluster_139134"; isCluster="true"; label="WholeStageCodegen (1)"; 53473 [id="node_53473" labelType="html" label="MapPartitionsRDD [53473] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139157 { id="cluster_139157"; isCluster="true"; label="Exchange"; 53484 [id="node_53484" labelType="html" label="ShuffledRowRDD [53484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139154 { id="cluster_139154"; isCluster="true"; label="WholeStageCodegen (4)"; 53485 [id="node_53485" labelType="html" label="MapPartitionsRDD [53485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139186 { id="cluster_139186"; isCluster="true"; label="Exchange"; 53488 [id="node_53488" labelType="html" label="ShuffledRowRDD [53488] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139183 { id="cluster_139183"; isCluster="true"; label="WholeStageCodegen (6)"; 53489 [id="node_53489" labelType="html" label="MapPartitionsRDD [53489] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139146 { id="cluster_139146"; isCluster="true"; label="WholeStageCodegen (7)"; 53490 [id="node_53490" labelType="html" label="ZippedPartitionsRDD2 [53490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53491 [id="node_53491" labelType="html" label="MapPartitionsRDD [53491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139145 { id="cluster_139145"; isCluster="true"; label="InMemoryTableScan"; 53492 [id="node_53492" labelType="html" label="MapPartitionsRDD [53492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53493 [id="node_53493" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1072650 AS qty#1072652, demandChannel#1072645, demandStream#1072646, cachedKpis#1072651 AS kpis#1072653]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1072649L, cachedShardId#1072648], 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=1691032]\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... [53493] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139143 { id="cluster_139143"; isCluster="true"; label="Exchange"; 53500 [id="node_53500" labelType="html" label="ShuffledRowRDD [53500] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139140 { id="cluster_139140"; isCluster="true"; label="WholeStageCodegen (4)"; 53501 [id="node_53501" labelType="html" label="MapPartitionsRDD [53501] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139126 { id="cluster_139126"; isCluster="true"; label="WholeStageCodegen (5)"; 53502 [id="node_53502" labelType="html" label="ZippedPartitionsRDD2 [53502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53503 [id="node_53503" labelType="html" label="MapPartitionsRDD [53503] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139201 { id="cluster_139201"; isCluster="true"; label="InMemoryTableScan"; 53504 [id="node_53504" labelType="html" label="MapPartitionsRDD [53504] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53505 [id="node_53505" labelType="html" label="MapPartitionsRDD [53505] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53506 [id="node_53506" labelType="html" label="MapPartitionsRDD [53506] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139198 { id="cluster_139198"; isCluster="true"; label="WholeStageCodegen (6)"; 53507 [id="node_53507" labelType="html" label="MapPartitionsRDD [53507] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139125 { id="cluster_139125"; isCluster="true"; label="Union"; 53508 [id="node_53508" labelType="html" label="UnionRDD [53508] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139124 { id="cluster_139124"; isCluster="true"; label="InMemoryTableScan"; 53509 [id="node_53509" labelType="html" label="MapPartitionsRDD [53509] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53510 [id="node_53510" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1072885, null AS demandStream#1072886, [] AS kpis#1072920, true AS isNewlyCalculated#1072888]\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#1072877, ), isnull(shardId#1072877), coalesce(worklistShardItemId#1072878L, 0), isnull(worklistShardItemId#1072878L), coalesce(version#1072879, 0), isnull(version#1072879), coalesce(product#1072880, ), isnull(product#1072880), coalesce(plant#1072881, ), isnull(plant#1072881), knownfloatingpointnormalized(normalizenanandzero(coalesce... [53510] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139413 { id="cluster_139413"; isCluster="true"; label="Exchange"; 53606 [id="node_53606" labelType="html" label="ShuffledRowRDD [53606] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139408 { id="cluster_139408"; isCluster="true"; label="WholeStageCodegen (6)"; 53607 [id="node_53607" labelType="html" label="MapPartitionsRDD [53607] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139407 { id="cluster_139407"; isCluster="true"; label="SortAggregate"; 53608 [id="node_53608" labelType="html" label="MapPartitionsRDD [53608] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139406 { id="cluster_139406"; isCluster="true"; label="InMemoryTableScan"; 53609 [id="node_53609" labelType="html" label="MapPartitionsRDD [53609] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53610 [id="node_53610" labelType="html" label="SortAggregate(key=[demandChannel#1075421, shardId#1011815, qty#1075441, worklistShardItemId#1011816L, demandStream#1075422], functions=[first(kpis#1075450, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1075441, demandChannel#1075421, demandStream#1075422, kpis#1075583])\n+- *(6) Sort [demandChannel#1075421 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1075441 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1075422 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1075421, shardId#1011815, qty#1075441, worklistShardItemId#1011816L, demandStream#1075422, 37), ENSURE_REQUIREMENTS, [plan_id=1691962]\n +- SortAggregate(key=[demandChannel#1075421, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1075441)) AS qty#1075441, worklistShardItemId#1011816L, demandStream#1075422], functions=[partial_first(kpis#1075450, false)], output=[demandChannel#1075421, shardId#1011815, qty#1075441, worklistShardItemId#1011816L,... [53610] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139573 { id="cluster_139573"; isCluster="true"; label="InMemoryTableScan"; 53648 [id="node_53648" labelType="html" label="MapPartitionsRDD [53648] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53649 [id="node_53649" labelType="html" label="MapPartitionsRDD [53649] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53650 [id="node_53650" labelType="html" label="MapPartitionsRDD [53650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139569 { id="cluster_139569"; isCluster="true"; label="WholeStageCodegen (1)"; 53651 [id="node_53651" labelType="html" label="MapPartitionsRDD [53651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139577 { id="cluster_139577"; isCluster="true"; label="InMemoryTableScan"; 53652 [id="node_53652" labelType="html" label="MapPartitionsRDD [53652] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53653 [id="node_53653" labelType="html" label="MapPartitionsRDD [53653] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53654 [id="node_53654" labelType="html" label="MapPartitionsRDD [53654] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139574 { id="cluster_139574"; isCluster="true"; label="WholeStageCodegen (2)"; 53655 [id="node_53655" labelType="html" label="MapPartitionsRDD [53655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139568 { id="cluster_139568"; isCluster="true"; label="Union"; 53656 [id="node_53656" labelType="html" label="UnionRDD [53656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139544 { id="cluster_139544"; isCluster="true"; label="WholeStageCodegen (5)"; 53657 [id="node_53657" labelType="html" label="MapPartitionsRDD [53657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139543 { id="cluster_139543"; isCluster="true"; label="InMemoryTableScan"; 53658 [id="node_53658" labelType="html" label="MapPartitionsRDD [53658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53659 [id="node_53659" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1076254, qty#1011822, demandChannel#1072885, demandStream#1072886, kpis#1072920]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1076351, worklistShardItemId#1076352L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1072885, demandStream#1072886, kpis#1072920]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1072888 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1072885, demandStream#1072886, isNewlyCalculated#1072888, kpis#1072920, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1072888, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [53659] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139602 { id="cluster_139602"; isCluster="true"; label="InMemoryTableScan"; 53668 [id="node_53668" labelType="html" label="MapPartitionsRDD [53668] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53669 [id="node_53669" labelType="html" label="MapPartitionsRDD [53669] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53670 [id="node_53670" labelType="html" label="MapPartitionsRDD [53670] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 53472->53473; 53484->53485; 53488->53489; 53485->53490; 53489->53490; 53490->53491; 53491->53492; 53492->53493; 53500->53501; 53473->53502; 53501->53502; 53502->53503; 53493->53504; 53504->53505; 53505->53506; 53506->53507; 53503->53508; 53507->53508; 53508->53509; 53509->53510; 53606->53607; 53607->53608; 53608->53609; 53609->53610; 53510->53648; 53648->53649; 53649->53650; 53650->53651; 53610->53652; 53652->53653; 53653->53654; 53654->53655; 53651->53656; 53655->53656; 53656->53657; 53657->53658; 53658->53659; 53659->53668; 53668->53669; 53669->53670; }