digraph G { id="graph_112010"; subgraph graph_stage_112010 { id="graph_stage_112010"; isCluster="true"; label="Stage 112010"; 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}"]; 53511 [id="node_53511" labelType="html" label="MapPartitionsRDD [53511] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53512 [id="node_53512" labelType="html" label="MapPartitionsRDD [53512] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53513 [id="node_53513" labelType="html" label="MapPartitionsRDD [53513] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139119 { id="cluster_139119"; isCluster="true"; label="WholeStageCodegen (15)"; 53514 [id="node_53514" labelType="html" label="MapPartitionsRDD [53514] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139118 { id="cluster_139118"; isCluster="true"; label="Exchange"; 53515 [id="node_53515" labelType="html" label="MapPartitionsRDD [53515] [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; 53510->53511; 53511->53512; 53512->53513; 53513->53514; 53514->53515; }