digraph G { id="graph_108407"; subgraph graph_stage_108407 { id="graph_stage_108407"; isCluster="true"; label="Stage 108407"; 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}"]; 52453 [id="node_52453" labelType="html" label="MapPartitionsRDD [52453] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52454 [id="node_52454" labelType="html" label="MapPartitionsRDD [52454] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52455 [id="node_52455" labelType="html" label="MapPartitionsRDD [52455] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136633 { id="cluster_136633"; isCluster="true"; label="WholeStageCodegen (15)"; 52456 [id="node_52456" labelType="html" label="MapPartitionsRDD [52456] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136632 { id="cluster_136632"; isCluster="true"; label="Exchange"; 52457 [id="node_52457" labelType="html" label="MapPartitionsRDD [52457] [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; 52452->52453; 52453->52454; 52454->52455; 52455->52456; 52456->52457; }