digraph G {
id="graph_657";
subgraph graph_stage_657 {
id="graph_stage_657";
isCluster="true";
label="Stage 657";
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_2889 {
id="cluster_2889";
isCluster="true";
label="Exchange";
1074 [id="node_1074" labelType="html" label="ShuffledRowRDD [1074] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2886 {
id="cluster_2886";
isCluster="true";
label="WholeStageCodegen (8)";
1075 [id="node_1075" labelType="html" label="MapPartitionsRDD [1075] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2885 {
id="cluster_2885";
isCluster="true";
label="SortAggregate";
1076 [id="node_1076" labelType="html" label="MapPartitionsRDD [1076] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_2884 {
id="cluster_2884";
isCluster="true";
label="InMemoryTableScan";
1077 [id="node_1077" labelType="html" label="MapPartitionsRDD [1077] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1078 [id="node_1078" labelType="html" label="SortAggregate(key=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[first(kpis#16018, false)], output=[shardId#445, worklistShardItemId#446L, qty#16009, demandChannel#15989, demandStream#15990, kpis#16151])\n+- *(8) Sort [demandChannel#15989 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#16009 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#15990 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, 37), ENSURE_REQUIREMENTS, [plan_id=115377]\n +- SortAggregate(key=[demandChannel#15989, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#16009)) AS qty#16009, worklistShardItemId#446L, demandStream#15990], functions=[partial_first(kpis#16018, false)], output=[demandChannel#15989, shardId#445, qty#16009, worklistShardItemId#446L, demandStream#15990, first#16227, valueSet#16228])\n +- *(7) Sort [demandChannel#159... [1078] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3064 {
id="cluster_3064";
isCluster="true";
label="InMemoryTableScan";
1116 [id="node_1116" labelType="html" label="MapPartitionsRDD [1116] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1117 [id="node_1117" labelType="html" label="MapPartitionsRDD [1117] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1118 [id="node_1118" labelType="html" label="MapPartitionsRDD [1118] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3060 {
id="cluster_3060";
isCluster="true";
label="WholeStageCodegen (1)";
1119 [id="node_1119" labelType="html" label="MapPartitionsRDD [1119] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3068 {
id="cluster_3068";
isCluster="true";
label="InMemoryTableScan";
1120 [id="node_1120" labelType="html" label="MapPartitionsRDD [1120] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1121 [id="node_1121" labelType="html" label="MapPartitionsRDD [1121] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1122 [id="node_1122" labelType="html" label="MapPartitionsRDD [1122] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3065 {
id="cluster_3065";
isCluster="true";
label="WholeStageCodegen (2)";
1123 [id="node_1123" labelType="html" label="MapPartitionsRDD [1123] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3059 {
id="cluster_3059";
isCluster="true";
label="Union";
1124 [id="node_1124" labelType="html" label="UnionRDD [1124] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3035 {
id="cluster_3035";
isCluster="true";
label="WholeStageCodegen (5)";
1125 [id="node_1125" labelType="html" label="MapPartitionsRDD [1125] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3034 {
id="cluster_3034";
isCluster="true";
label="InMemoryTableScan";
1126 [id="node_1126" labelType="html" label="MapPartitionsRDD [1126] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1127 [id="node_1127" labelType="html" label="*(5) Project [shardId#445, worklistShardItemId#446L, version#16822, qty#452, demandChannel#13245, demandStream#13246, kpis#13280]\n+- *(5) BroadcastHashJoin [shardId#445, worklistShardItemId#446L], [shardId#16919, worklistShardItemId#16920L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#445, worklistShardItemId#446L, qty#452, demandChannel#13245, demandStream#13246, kpis#13280]\n : : +- *(1) Filter ((NOT isNewlyCalculated#13248 AND isnotnull(shardId#445)) AND isnotnull(worklistShardItemId#446L))\n : : +- InMemoryTableScan [demandChannel#13245, demandStream#13246, isNewlyCalculated#13248, kpis#13280, qty#452, shardId#445, worklistShardItemId#446L], [NOT isNewlyCalculated#13248, isnotnull(shardId#445), isnotnull(worklistShardItemId#446L)]\n : : +- InMemoryRelation [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, demandChannel#13245, demandStream#13246, kpis#13280, isNewlyCalculated#13248], StorageLevel(disk, memory, 2 replicas)\n ... [1127] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_3093 {
id="cluster_3093";
isCluster="true";
label="InMemoryTableScan";
1136 [id="node_1136" labelType="html" label="MapPartitionsRDD [1136] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1137 [id="node_1137" labelType="html" label="MapPartitionsRDD [1137] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
1138 [id="node_1138" labelType="html" label="MapPartitionsRDD [1138] [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;
1074->1075;
1075->1076;
1076->1077;
1077->1078;
949->1116;
1116->1117;
1117->1118;
1118->1119;
1078->1120;
1120->1121;
1121->1122;
1122->1123;
1119->1124;
1123->1124;
1124->1125;
1125->1126;
1126->1127;
1127->1136;
1136->1137;
1137->1138;
}
888,889
904,905
908,909
914,915
938,939
1073,1074
920
949
1078
1127