digraph G {
id="graph_499";
subgraph graph_stage_499 {
id="graph_stage_499";
isCluster="true";
label="Stage 499";
subgraph cluster_2548 {
id="cluster_2548";
isCluster="true";
label="Exchange";
905 [id="node_905" labelType="html" label="ShuffledRowRDD [905] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2545 {
id="cluster_2545";
isCluster="true";
label="WholeStageCodegen (2)";
906 [id="node_906" labelType="html" label="MapPartitionsRDD [906] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2557 {
id="cluster_2557";
isCluster="true";
label="Exchange";
909 [id="node_909" labelType="html" label="ShuffledRowRDD [909] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2554 {
id="cluster_2554";
isCluster="true";
label="WholeStageCodegen (4)";
910 [id="node_910" labelType="html" label="MapPartitionsRDD [910] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2538 {
id="cluster_2538";
isCluster="true";
label="WholeStageCodegen (5)";
911 [id="node_911" labelType="html" label="ZippedPartitionsRDD2 [911] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
912 [id="node_912" labelType="html" label="MapPartitionsRDD [912] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2566 {
id="cluster_2566";
isCluster="true";
label="Exchange";
915 [id="node_915" labelType="html" label="ShuffledRowRDD [915] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2563 {
id="cluster_2563";
isCluster="true";
label="WholeStageCodegen (7)";
916 [id="node_916" labelType="html" label="MapPartitionsRDD [916] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2534 {
id="cluster_2534";
isCluster="true";
label="WholeStageCodegen (8)";
917 [id="node_917" labelType="html" label="ZippedPartitionsRDD2 [917] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
918 [id="node_918" labelType="html" label="MapPartitionsRDD [918] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2533 {
id="cluster_2533";
isCluster="true";
label="InMemoryTableScan";
919 [id="node_919" labelType="html" label="MapPartitionsRDD [919] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
920 [id="node_920" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#13010 AS qty#13012, demandChannel#13005, demandStream#13006, cachedKpis#13011 AS kpis#13013]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#13009L, cachedShardId#13008], 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]... [920] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
921 [id="node_921" labelType="html" label="MapPartitionsRDD [921] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
922 [id="node_922" labelType="html" label="MapPartitionsRDD [922] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
923 [id="node_923" labelType="html" label="MapPartitionsRDD [923] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2578 {
id="cluster_2578";
isCluster="true";
label="Exchange";
929 [id="node_929" labelType="html" label="ShuffledRowRDD [929] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2575 {
id="cluster_2575";
isCluster="true";
label="WholeStageCodegen (3)";
930 [id="node_930" labelType="html" label="MapPartitionsRDD [930] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2587 {
id="cluster_2587";
isCluster="true";
label="Exchange";
933 [id="node_933" labelType="html" label="ShuffledRowRDD [933] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2584 {
id="cluster_2584";
isCluster="true";
label="WholeStageCodegen (5)";
934 [id="node_934" labelType="html" label="MapPartitionsRDD [934] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2571 {
id="cluster_2571";
isCluster="true";
label="WholeStageCodegen (6)";
935 [id="node_935" labelType="html" label="ZippedPartitionsRDD2 [935] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
936 [id="node_936" labelType="html" label="MapPartitionsRDD [936] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2532 {
id="cluster_2532";
isCluster="true";
label="Union";
937 [id="node_937" labelType="html" label="UnionRDD [937] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2531 {
id="cluster_2531";
isCluster="true";
label="Exchange";
938 [id="node_938" labelType="html" label="MapPartitionsRDD [938] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
905->906;
909->910;
906->911;
910->911;
911->912;
915->916;
912->917;
916->917;
917->918;
918->919;
919->920;
920->921;
921->922;
922->923;
929->930;
933->934;
930->935;
934->935;
935->936;
923->937;
936->937;
937->938;
}
904,905
908,909
914,915
928,929
932,933
920