digraph G {
id="graph_522";
subgraph graph_stage_522 {
id="graph_stage_522";
isCluster="true";
label="Stage 522";
subgraph cluster_2521 {
id="cluster_2521";
isCluster="true";
label="Exchange";
889 [id="node_889" labelType="html" label="ShuffledRowRDD [889] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2518 {
id="cluster_2518";
isCluster="true";
label="WholeStageCodegen (1)";
890 [id="node_890" labelType="html" label="MapPartitionsRDD [890] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
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}"];
}
subgraph cluster_2531 {
id="cluster_2531";
isCluster="true";
label="Exchange";
939 [id="node_939" labelType="html" label="ShuffledRowRDD [939] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2524 {
id="cluster_2524";
isCluster="true";
label="WholeStageCodegen (7)";
940 [id="node_940" labelType="html" label="MapPartitionsRDD [940] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2512 {
id="cluster_2512";
isCluster="true";
label="WholeStageCodegen (8)";
941 [id="node_941" labelType="html" label="ZippedPartitionsRDD2 [941] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
942 [id="node_942" labelType="html" label="MapPartitionsRDD [942] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2595 {
id="cluster_2595";
isCluster="true";
label="InMemoryTableScan";
943 [id="node_943" labelType="html" label="MapPartitionsRDD [943] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
944 [id="node_944" labelType="html" label="MapPartitionsRDD [944] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
945 [id="node_945" labelType="html" label="MapPartitionsRDD [945] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2592 {
id="cluster_2592";
isCluster="true";
label="WholeStageCodegen (9)";
946 [id="node_946" labelType="html" label="MapPartitionsRDD [946] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2511 {
id="cluster_2511";
isCluster="true";
label="Union";
947 [id="node_947" labelType="html" label="UnionRDD [947] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2510 {
id="cluster_2510";
isCluster="true";
label="InMemoryTableScan";
948 [id="node_948" labelType="html" label="MapPartitionsRDD [948] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
949 [id="node_949" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#13245, null AS demandStream#13246, [] AS kpis#13280, true AS isNewlyCalculated#13248]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#13237, ), isnull(shardId#13237), coalesce(worklistShardItemId#13238L, 0), isnull(worklistShardItemId#13238L), coalesce(version#13239, 0), isnull(version#13239), coalesce(product#13240, ), isnull(product#13240), coalesce(plant#13241, ), isnull(plant#13241), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#13012, 0.0))), isnull(qty#13012)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [949] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2769 {
id="cluster_2769";
isCluster="true";
label="Exchange";
1001 [id="node_1001" labelType="html" label="ShuffledRowRDD [1001] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2768 {
id="cluster_2768";
isCluster="true";
label="ObjectHashAggregate";
1002 [id="node_1002" labelType="html" label="MapPartitionsRDD [1002] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2780 {
id="cluster_2780";
isCluster="true";
label="InMemoryTableScan";
1003 [id="node_1003" labelType="html" label="MapPartitionsRDD [1003] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1004 [id="node_1004" labelType="html" label="MapPartitionsRDD [1004] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1005 [id="node_1005" labelType="html" label="MapPartitionsRDD [1005] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2776 {
id="cluster_2776";
isCluster="true";
label="WholeStageCodegen (11)";
1006 [id="node_1006" labelType="html" label="MapPartitionsRDD [1006] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2767 {
id="cluster_2767";
isCluster="true";
label="Union";
1007 [id="node_1007" labelType="html" label="UnionRDD [1007] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2766 {
id="cluster_2766";
isCluster="true";
label="Exchange";
1008 [id="node_1008" labelType="html" label="MapPartitionsRDD [1008] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
889->890;
905->906;
909->910;
906->911;
910->911;
911->912;
915->916;
912->917;
916->917;
917->918;
918->919;
919->920;
939->940;
890->941;
940->941;
941->942;
920->943;
943->944;
944->945;
945->946;
942->947;
946->947;
947->948;
948->949;
1001->1002;
949->1003;
1003->1004;
1004->1005;
1005->1006;
1002->1007;
1006->1007;
1007->1008;
}
888,889
904,905
908,909
914,915
938,939
1000,1001
920
949