digraph G { id="graph_117036"; subgraph graph_stage_117036 { id="graph_stage_117036"; isCluster="true"; label="Stage 117036"; subgraph cluster_146435 { id="cluster_146435"; isCluster="true"; label="map"; 56367 [id="node_56367" labelType="html" label="MapPartitionsRDD [56367] [Cached] [Indeterminate]<br>map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_146452 { id="cluster_146452"; isCluster="true"; label="checkpoint"; 56376 [id="node_56376" labelType="html" label="LocalCheckpointRDD [56376]<br>count at CachePortImpl.java:132}"]; } subgraph cluster_146610 { id="cluster_146610"; isCluster="true"; label="map"; 56448 [id="node_56448" labelType="html" label="MapPartitionsRDD [56448] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146673 { id="cluster_146673"; isCluster="true"; label="Exchange"; 56477 [id="node_56477" labelType="html" label="ShuffledRowRDD [56477] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146670 { id="cluster_146670"; isCluster="true"; label="WholeStageCodegen (4)"; 56478 [id="node_56478" labelType="html" label="MapPartitionsRDD [56478] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146708 { id="cluster_146708"; isCluster="true"; label="Exchange"; 56481 [id="node_56481" labelType="html" label="ShuffledRowRDD [56481] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146705 { id="cluster_146705"; isCluster="true"; label="WholeStageCodegen (6)"; 56482 [id="node_56482" labelType="html" label="MapPartitionsRDD [56482] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146662 { id="cluster_146662"; isCluster="true"; label="WholeStageCodegen (7)"; 56483 [id="node_56483" labelType="html" label="ZippedPartitionsRDD2 [56483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56484 [id="node_56484" labelType="html" label="MapPartitionsRDD [56484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146661 { id="cluster_146661"; isCluster="true"; label="InMemoryTableScan"; 56485 [id="node_56485" labelType="html" label="MapPartitionsRDD [56485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56486 [id="node_56486" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1134002 AS qty#1134004, demandChannel#1133997, demandStream#1133998, cachedKpis#1134003 AS kpis#1134005]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1134001L, cachedShardId#1134000], 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=1756957]\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... [56486] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56487 [id="node_56487" labelType="html" label="MapPartitionsRDD [56487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56488 [id="node_56488" labelType="html" label="MapPartitionsRDD [56488] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56489 [id="node_56489" labelType="html" label="MapPartitionsRDD [56489] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146713 { id="cluster_146713"; isCluster="true"; label="WholeStageCodegen (3)"; 56490 [id="node_56490" labelType="html" label="MapPartitionsRDD [56490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146660 { id="cluster_146660"; isCluster="true"; label="Union"; 56491 [id="node_56491" labelType="html" label="UnionRDD [56491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146659 { id="cluster_146659"; isCluster="true"; label="Exchange"; 56492 [id="node_56492" labelType="html" label="MapPartitionsRDD [56492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56376->56367; 56367->56448; 56477->56478; 56481->56482; 56478->56483; 56482->56483; 56483->56484; 56484->56485; 56485->56486; 56486->56487; 56487->56488; 56488->56489; 56448->56490; 56489->56491; 56490->56491; 56491->56492; }