digraph G { id="graph_115433"; subgraph graph_stage_115433 { id="graph_stage_115433"; isCluster="true"; label="Stage 115433"; subgraph cluster_144174 { id="cluster_144174"; isCluster="true"; label="Exchange"; 55415 [id="node_55415" labelType="html" label="ShuffledRowRDD [55415] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144171 { id="cluster_144171"; isCluster="true"; label="WholeStageCodegen (4)"; 55416 [id="node_55416" labelType="html" label="MapPartitionsRDD [55416] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144209 { id="cluster_144209"; isCluster="true"; label="Exchange"; 55419 [id="node_55419" labelType="html" label="ShuffledRowRDD [55419] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144206 { id="cluster_144206"; isCluster="true"; label="WholeStageCodegen (6)"; 55420 [id="node_55420" labelType="html" label="MapPartitionsRDD [55420] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144163 { id="cluster_144163"; isCluster="true"; label="WholeStageCodegen (7)"; 55421 [id="node_55421" labelType="html" label="ZippedPartitionsRDD2 [55421] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55422 [id="node_55422" labelType="html" label="MapPartitionsRDD [55422] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144162 { id="cluster_144162"; isCluster="true"; label="InMemoryTableScan"; 55423 [id="node_55423" labelType="html" label="MapPartitionsRDD [55423] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55424 [id="node_55424" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1111580 AS qty#1111582, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581 AS kpis#1111583]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1111579L, cachedShardId#1111578], 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=1750595]\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... [55424] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55425 [id="node_55425" labelType="html" label="MapPartitionsRDD [55425] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55426 [id="node_55426" labelType="html" label="MapPartitionsRDD [55426] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 55427 [id="node_55427" labelType="html" label="MapPartitionsRDD [55427] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144161 { id="cluster_144161"; isCluster="true"; label="Union"; 55429 [id="node_55429" labelType="html" label="UnionRDD [55429] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144160 { id="cluster_144160"; isCluster="true"; label="Exchange"; 55430 [id="node_55430" labelType="html" label="MapPartitionsRDD [55430] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 55415->55416; 55419->55420; 55416->55421; 55420->55421; 55421->55422; 55422->55423; 55423->55424; 55424->55425; 55425->55426; 55426->55427; 55427->55429; 55429->55430; }