digraph G { id="graph_112044"; subgraph graph_stage_112044 { id="graph_stage_112044"; isCluster="true"; label="Stage 112044"; 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_139335 { id="cluster_139335"; isCluster="true"; label="Exchange"; 53555 [id="node_53555" labelType="html" label="ShuffledRowRDD [53555] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139334 { id="cluster_139334"; isCluster="true"; label="ObjectHashAggregate"; 53556 [id="node_53556" labelType="html" label="MapPartitionsRDD [53556] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139346 { id="cluster_139346"; isCluster="true"; label="InMemoryTableScan"; 53557 [id="node_53557" labelType="html" label="MapPartitionsRDD [53557] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53558 [id="node_53558" labelType="html" label="MapPartitionsRDD [53558] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53559 [id="node_53559" labelType="html" label="MapPartitionsRDD [53559] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139342 { id="cluster_139342"; isCluster="true"; label="WholeStageCodegen (12)"; 53560 [id="node_53560" labelType="html" label="MapPartitionsRDD [53560] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139333 { id="cluster_139333"; isCluster="true"; label="Union"; 53561 [id="node_53561" labelType="html" label="UnionRDD [53561] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139332 { id="cluster_139332"; isCluster="true"; label="Exchange"; 53562 [id="node_53562" labelType="html" label="MapPartitionsRDD [53562] [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; 53555->53556; 53510->53557; 53557->53558; 53558->53559; 53559->53560; 53556->53561; 53560->53561; 53561->53562; }