digraph G { id="graph_117207"; subgraph graph_stage_117207 { id="graph_stage_117207"; isCluster="true"; label="Stage 117207"; subgraph cluster_147040 { id="cluster_147040"; isCluster="true"; label="repartition"; 56630 [id="node_56630" labelType="html" label="ShuffledRDD [56630] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56631 [id="node_56631" labelType="html" label="CoalescedRDD [56631] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56632 [id="node_56632" labelType="html" label="MapPartitionsRDD [56632] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147231 { id="cluster_147231"; isCluster="true"; label="map"; 56712 [id="node_56712" labelType="html" label="MapPartitionsRDD [56712] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147294 { id="cluster_147294"; isCluster="true"; label="Exchange"; 56741 [id="node_56741" labelType="html" label="ShuffledRowRDD [56741] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147291 { id="cluster_147291"; isCluster="true"; label="WholeStageCodegen (4)"; 56742 [id="node_56742" labelType="html" label="MapPartitionsRDD [56742] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147329 { id="cluster_147329"; isCluster="true"; label="Exchange"; 56745 [id="node_56745" labelType="html" label="ShuffledRowRDD [56745] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147326 { id="cluster_147326"; isCluster="true"; label="WholeStageCodegen (6)"; 56746 [id="node_56746" labelType="html" label="MapPartitionsRDD [56746] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147283 { id="cluster_147283"; isCluster="true"; label="WholeStageCodegen (7)"; 56747 [id="node_56747" labelType="html" label="ZippedPartitionsRDD2 [56747] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56748 [id="node_56748" labelType="html" label="MapPartitionsRDD [56748] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147282 { id="cluster_147282"; isCluster="true"; label="InMemoryTableScan"; 56749 [id="node_56749" labelType="html" label="MapPartitionsRDD [56749] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56750 [id="node_56750" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1139560 AS qty#1139562, demandChannel#1139555, demandStream#1139556, cachedKpis#1139561 AS kpis#1139563]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1139559L, cachedShardId#1139558], 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=1758547]\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... [56750] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56751 [id="node_56751" labelType="html" label="MapPartitionsRDD [56751] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56752 [id="node_56752" labelType="html" label="MapPartitionsRDD [56752] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56753 [id="node_56753" labelType="html" label="MapPartitionsRDD [56753] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147334 { id="cluster_147334"; isCluster="true"; label="WholeStageCodegen (3)"; 56754 [id="node_56754" labelType="html" label="MapPartitionsRDD [56754] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147281 { id="cluster_147281"; isCluster="true"; label="Union"; 56755 [id="node_56755" labelType="html" label="UnionRDD [56755] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147280 { id="cluster_147280"; isCluster="true"; label="Exchange"; 56756 [id="node_56756" labelType="html" label="MapPartitionsRDD [56756] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56630->56631; 56631->56632; 56632->56712; 56741->56742; 56745->56746; 56742->56747; 56746->56747; 56747->56748; 56748->56749; 56749->56750; 56750->56751; 56751->56752; 56752->56753; 56712->56754; 56753->56755; 56754->56755; 56755->56756; }