digraph G { id="graph_708"; subgraph graph_stage_708 { id="graph_stage_708"; isCluster="true"; label="Stage 708"; subgraph cluster_3274 { id="cluster_3274"; isCluster="true"; label="Exchange"; 1201 [id="node_1201" labelType="html" label="ShuffledRowRDD [1201] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3271 { id="cluster_3271"; isCluster="true"; label="WholeStageCodegen (2)"; 1202 [id="node_1202" labelType="html" label="MapPartitionsRDD [1202] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3283 { id="cluster_3283"; isCluster="true"; label="Exchange"; 1205 [id="node_1205" labelType="html" label="ShuffledRowRDD [1205] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3280 { id="cluster_3280"; isCluster="true"; label="WholeStageCodegen (4)"; 1208 [id="node_1208" labelType="html" label="MapPartitionsRDD [1208] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3262 { id="cluster_3262"; isCluster="true"; label="WholeStageCodegen (5)"; 1212 [id="node_1212" labelType="html" label="ZippedPartitionsRDD2 [1212] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1215 [id="node_1215" labelType="html" label="MapPartitionsRDD [1215] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3292 { id="cluster_3292"; isCluster="true"; label="Exchange"; 1218 [id="node_1218" labelType="html" label="ShuffledRowRDD [1218] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3289 { id="cluster_3289"; isCluster="true"; label="WholeStageCodegen (7)"; 1219 [id="node_1219" labelType="html" label="MapPartitionsRDD [1219] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3258 { id="cluster_3258"; isCluster="true"; label="WholeStageCodegen (8)"; 1220 [id="node_1220" labelType="html" label="ZippedPartitionsRDD2 [1220] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1221 [id="node_1221" labelType="html" label="MapPartitionsRDD [1221] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3257 { id="cluster_3257"; isCluster="true"; label="InMemoryTableScan"; 1222 [id="node_1222" labelType="html" label="MapPartitionsRDD [1222] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1223 [id="node_1223" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1223] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1224 [id="node_1224" labelType="html" label="MapPartitionsRDD [1224] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1225 [id="node_1225" labelType="html" label="MapPartitionsRDD [1225] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1226 [id="node_1226" labelType="html" label="MapPartitionsRDD [1226] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3308 { id="cluster_3308"; isCluster="true"; label="Exchange"; 1232 [id="node_1232" labelType="html" label="ShuffledRowRDD [1232] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3305 { id="cluster_3305"; isCluster="true"; label="WholeStageCodegen (3)"; 1233 [id="node_1233" labelType="html" label="MapPartitionsRDD [1233] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3317 { id="cluster_3317"; isCluster="true"; label="Exchange"; 1236 [id="node_1236" labelType="html" label="ShuffledRowRDD [1236] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3314 { id="cluster_3314"; isCluster="true"; label="WholeStageCodegen (5)"; 1237 [id="node_1237" labelType="html" label="MapPartitionsRDD [1237] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3297 { id="cluster_3297"; isCluster="true"; label="WholeStageCodegen (6)"; 1238 [id="node_1238" labelType="html" label="ZippedPartitionsRDD2 [1238] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1239 [id="node_1239" labelType="html" label="MapPartitionsRDD [1239] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3256 { id="cluster_3256"; isCluster="true"; label="Union"; 1240 [id="node_1240" labelType="html" label="UnionRDD [1240] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3255 { id="cluster_3255"; isCluster="true"; label="Exchange"; 1241 [id="node_1241" labelType="html" label="MapPartitionsRDD [1241] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 1201->1202; 1205->1208; 1202->1212; 1208->1212; 1212->1215; 1218->1219; 1215->1220; 1219->1220; 1220->1221; 1221->1222; 1222->1223; 1223->1224; 1224->1225; 1225->1226; 1232->1233; 1236->1237; 1233->1238; 1237->1238; 1238->1239; 1226->1240; 1239->1240; 1240->1241; }