digraph G { id="graph_119513"; subgraph graph_stage_119513 { id="graph_stage_119513"; isCluster="true"; label="Stage 119513"; subgraph cluster_149524 { id="cluster_149524"; isCluster="true"; label="repartition"; 57686 [id="node_57686" labelType="html" label="ShuffledRDD [57686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57687 [id="node_57687" labelType="html" label="CoalescedRDD [57687] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57688 [id="node_57688" labelType="html" label="MapPartitionsRDD [57688] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149715 { id="cluster_149715"; isCluster="true"; label="map"; 57768 [id="node_57768" labelType="html" label="MapPartitionsRDD [57768] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149778 { id="cluster_149778"; isCluster="true"; label="Exchange"; 57797 [id="node_57797" labelType="html" label="ShuffledRowRDD [57797] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149775 { id="cluster_149775"; isCluster="true"; label="WholeStageCodegen (4)"; 57798 [id="node_57798" labelType="html" label="MapPartitionsRDD [57798] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149807 { id="cluster_149807"; isCluster="true"; label="Exchange"; 57801 [id="node_57801" labelType="html" label="ShuffledRowRDD [57801] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149804 { id="cluster_149804"; isCluster="true"; label="WholeStageCodegen (6)"; 57802 [id="node_57802" labelType="html" label="MapPartitionsRDD [57802] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149767 { id="cluster_149767"; isCluster="true"; label="WholeStageCodegen (7)"; 57803 [id="node_57803" labelType="html" label="ZippedPartitionsRDD2 [57803] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57804 [id="node_57804" labelType="html" label="MapPartitionsRDD [57804] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149766 { id="cluster_149766"; isCluster="true"; label="InMemoryTableScan"; 57805 [id="node_57805" labelType="html" label="MapPartitionsRDD [57805] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57806 [id="node_57806" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1161792 AS qty#1161794, demandChannel#1161787, demandStream#1161788, cachedKpis#1161793 AS kpis#1161795]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1161791L, cachedShardId#1161790], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1764825]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [57806] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57807 [id="node_57807" labelType="html" label="MapPartitionsRDD [57807] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57808 [id="node_57808" labelType="html" label="MapPartitionsRDD [57808] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57809 [id="node_57809" labelType="html" label="MapPartitionsRDD [57809] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149812 { id="cluster_149812"; isCluster="true"; label="WholeStageCodegen (3)"; 57810 [id="node_57810" labelType="html" label="MapPartitionsRDD [57810] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149765 { id="cluster_149765"; isCluster="true"; label="Union"; 57811 [id="node_57811" labelType="html" label="UnionRDD [57811] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149764 { id="cluster_149764"; isCluster="true"; label="Exchange"; 57812 [id="node_57812" labelType="html" label="MapPartitionsRDD [57812] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57686->57687; 57687->57688; 57688->57768; 57797->57798; 57801->57802; 57798->57803; 57802->57803; 57803->57804; 57804->57805; 57805->57806; 57806->57807; 57807->57808; 57808->57809; 57768->57810; 57809->57811; 57810->57811; 57811->57812; }