digraph G { id="graph_108514"; subgraph graph_stage_108514 { id="graph_stage_108514"; isCluster="true"; label="Stage 108514"; subgraph cluster_136651 { id="cluster_136651"; isCluster="true"; label="Exchange"; 52414 [id="node_52414" labelType="html" label="ShuffledRowRDD [52414] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136648 { id="cluster_136648"; isCluster="true"; label="WholeStageCodegen (1)"; 52415 [id="node_52415" labelType="html" label="MapPartitionsRDD [52415] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136671 { id="cluster_136671"; isCluster="true"; label="Exchange"; 52426 [id="node_52426" labelType="html" label="ShuffledRowRDD [52426] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136668 { id="cluster_136668"; isCluster="true"; label="WholeStageCodegen (4)"; 52427 [id="node_52427" labelType="html" label="MapPartitionsRDD [52427] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136706 { id="cluster_136706"; isCluster="true"; label="Exchange"; 52430 [id="node_52430" labelType="html" label="ShuffledRowRDD [52430] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136703 { id="cluster_136703"; isCluster="true"; label="WholeStageCodegen (6)"; 52431 [id="node_52431" labelType="html" label="MapPartitionsRDD [52431] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136660 { id="cluster_136660"; isCluster="true"; label="WholeStageCodegen (7)"; 52432 [id="node_52432" labelType="html" label="ZippedPartitionsRDD2 [52432] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52433 [id="node_52433" labelType="html" label="MapPartitionsRDD [52433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136659 { id="cluster_136659"; isCluster="true"; label="InMemoryTableScan"; 52434 [id="node_52434" labelType="html" label="MapPartitionsRDD [52434] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52435 [id="node_52435" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1050418 AS qty#1050420, demandChannel#1050413, demandStream#1050414, cachedKpis#1050419 AS kpis#1050421]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1050417L, cachedShardId#1050416], 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=1684687]\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... [52435] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136657 { id="cluster_136657"; isCluster="true"; label="Exchange"; 52442 [id="node_52442" labelType="html" label="ShuffledRowRDD [52442] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136654 { id="cluster_136654"; isCluster="true"; label="WholeStageCodegen (4)"; 52443 [id="node_52443" labelType="html" label="MapPartitionsRDD [52443] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136640 { id="cluster_136640"; isCluster="true"; label="WholeStageCodegen (5)"; 52444 [id="node_52444" labelType="html" label="ZippedPartitionsRDD2 [52444] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52445 [id="node_52445" labelType="html" label="MapPartitionsRDD [52445] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136721 { id="cluster_136721"; isCluster="true"; label="InMemoryTableScan"; 52446 [id="node_52446" labelType="html" label="MapPartitionsRDD [52446] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52447 [id="node_52447" labelType="html" label="MapPartitionsRDD [52447] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52448 [id="node_52448" labelType="html" label="MapPartitionsRDD [52448] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136718 { id="cluster_136718"; isCluster="true"; label="WholeStageCodegen (6)"; 52449 [id="node_52449" labelType="html" label="MapPartitionsRDD [52449] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136639 { id="cluster_136639"; isCluster="true"; label="Union"; 52450 [id="node_52450" labelType="html" label="UnionRDD [52450] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136638 { id="cluster_136638"; isCluster="true"; label="InMemoryTableScan"; 52451 [id="node_52451" labelType="html" label="MapPartitionsRDD [52451] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52452 [id="node_52452" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1050653, null AS demandStream#1050654, [] AS kpis#1050688, true AS isNewlyCalculated#1050656]\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#1050645, ), isnull(shardId#1050645), coalesce(worklistShardItemId#1050646L, 0), isnull(worklistShardItemId#1050646L), coalesce(version#1050647, 0), isnull(version#1050647), coalesce(product#1050648, ), isnull(product#1050648), coalesce(plant#1050649, ), isnull(plant#1050649), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52452] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136849 { id="cluster_136849"; isCluster="true"; label="Exchange"; 52497 [id="node_52497" labelType="html" label="ShuffledRowRDD [52497] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136848 { id="cluster_136848"; isCluster="true"; label="ObjectHashAggregate"; 52498 [id="node_52498" labelType="html" label="MapPartitionsRDD [52498] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136860 { id="cluster_136860"; isCluster="true"; label="InMemoryTableScan"; 52499 [id="node_52499" labelType="html" label="MapPartitionsRDD [52499] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52500 [id="node_52500" labelType="html" label="MapPartitionsRDD [52500] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52501 [id="node_52501" labelType="html" label="MapPartitionsRDD [52501] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136856 { id="cluster_136856"; isCluster="true"; label="WholeStageCodegen (12)"; 52502 [id="node_52502" labelType="html" label="MapPartitionsRDD [52502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136847 { id="cluster_136847"; isCluster="true"; label="Union"; 52503 [id="node_52503" labelType="html" label="UnionRDD [52503] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136846 { id="cluster_136846"; isCluster="true"; label="Exchange"; 52504 [id="node_52504" labelType="html" label="MapPartitionsRDD [52504] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52414->52415; 52426->52427; 52430->52431; 52427->52432; 52431->52432; 52432->52433; 52433->52434; 52434->52435; 52442->52443; 52415->52444; 52443->52444; 52444->52445; 52435->52446; 52446->52447; 52447->52448; 52448->52449; 52445->52450; 52449->52450; 52450->52451; 52451->52452; 52497->52498; 52452->52499; 52499->52500; 52500->52501; 52501->52502; 52498->52503; 52502->52503; 52503->52504; }