digraph G {
id="graph_117900";
subgraph graph_stage_117900 {
id="graph_stage_117900";
isCluster="true";
label="Stage 117900";
subgraph cluster_147895 {
id="cluster_147895";
isCluster="true";
label="Exchange";
56993 [id="node_56993" labelType="html" label="ShuffledRowRDD [56993] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147892 {
id="cluster_147892";
isCluster="true";
label="WholeStageCodegen (1)";
56994 [id="node_56994" labelType="html" label="MapPartitionsRDD [56994] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147915 {
id="cluster_147915";
isCluster="true";
label="Exchange";
57005 [id="node_57005" labelType="html" label="ShuffledRowRDD [57005] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147912 {
id="cluster_147912";
isCluster="true";
label="WholeStageCodegen (4)";
57006 [id="node_57006" labelType="html" label="MapPartitionsRDD [57006] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147944 {
id="cluster_147944";
isCluster="true";
label="Exchange";
57009 [id="node_57009" labelType="html" label="ShuffledRowRDD [57009] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147941 {
id="cluster_147941";
isCluster="true";
label="WholeStageCodegen (6)";
57010 [id="node_57010" labelType="html" label="MapPartitionsRDD [57010] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147904 {
id="cluster_147904";
isCluster="true";
label="WholeStageCodegen (7)";
57011 [id="node_57011" labelType="html" label="ZippedPartitionsRDD2 [57011] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57012 [id="node_57012" labelType="html" label="MapPartitionsRDD [57012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147903 {
id="cluster_147903";
isCluster="true";
label="InMemoryTableScan";
57013 [id="node_57013" labelType="html" label="MapPartitionsRDD [57013] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57014 [id="node_57014" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1145118 AS qty#1145120, demandChannel#1145113, demandStream#1145114, cachedKpis#1145119 AS kpis#1145121]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1145117L, cachedShardId#1145116], 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=1760137]\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... [57014] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147901 {
id="cluster_147901";
isCluster="true";
label="Exchange";
57021 [id="node_57021" labelType="html" label="ShuffledRowRDD [57021] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147898 {
id="cluster_147898";
isCluster="true";
label="WholeStageCodegen (4)";
57022 [id="node_57022" labelType="html" label="MapPartitionsRDD [57022] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147884 {
id="cluster_147884";
isCluster="true";
label="WholeStageCodegen (5)";
57023 [id="node_57023" labelType="html" label="ZippedPartitionsRDD2 [57023] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57024 [id="node_57024" labelType="html" label="MapPartitionsRDD [57024] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147959 {
id="cluster_147959";
isCluster="true";
label="InMemoryTableScan";
57025 [id="node_57025" labelType="html" label="MapPartitionsRDD [57025] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57026 [id="node_57026" labelType="html" label="MapPartitionsRDD [57026] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57027 [id="node_57027" labelType="html" label="MapPartitionsRDD [57027] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147956 {
id="cluster_147956";
isCluster="true";
label="WholeStageCodegen (6)";
57028 [id="node_57028" labelType="html" label="MapPartitionsRDD [57028] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147883 {
id="cluster_147883";
isCluster="true";
label="Union";
57029 [id="node_57029" labelType="html" label="UnionRDD [57029] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_147882 {
id="cluster_147882";
isCluster="true";
label="InMemoryTableScan";
57030 [id="node_57030" labelType="html" label="MapPartitionsRDD [57030] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57031 [id="node_57031" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1145353, null AS demandStream#1145354, [] AS kpis#1145388, true AS isNewlyCalculated#1145356]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1145345, ), isnull(shardId#1145345), coalesce(worklistShardItemId#1145346L, 0), isnull(worklistShardItemId#1145346L), coalesce(version#1145347, 0), isnull(version#1145347), coalesce(product#1145348, ), isnull(product#1145348), coalesce(plant#1145349, ), isnull(plant#1145349), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57031] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148171 {
id="cluster_148171";
isCluster="true";
label="Exchange";
57127 [id="node_57127" labelType="html" label="ShuffledRowRDD [57127] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148166 {
id="cluster_148166";
isCluster="true";
label="WholeStageCodegen (6)";
57128 [id="node_57128" labelType="html" label="MapPartitionsRDD [57128] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148165 {
id="cluster_148165";
isCluster="true";
label="SortAggregate";
57129 [id="node_57129" labelType="html" label="MapPartitionsRDD [57129] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148164 {
id="cluster_148164";
isCluster="true";
label="InMemoryTableScan";
57130 [id="node_57130" labelType="html" label="MapPartitionsRDD [57130] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57131 [id="node_57131" labelType="html" label="SortAggregate(key=[demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[first(kpis#1147918, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1147909, demandChannel#1147889, demandStream#1147890, kpis#1148051])\n+- *(6) Sort [demandChannel#1147889 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1147909 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1147890 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890, 37), ENSURE_REQUIREMENTS, [plan_id=1761067]\n +- SortAggregate(key=[demandChannel#1147889, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1147909)) AS qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[partial_first(kpis#1147918, false)], output=[demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L,... [57131] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148331 {
id="cluster_148331";
isCluster="true";
label="InMemoryTableScan";
57169 [id="node_57169" labelType="html" label="MapPartitionsRDD [57169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57170 [id="node_57170" labelType="html" label="MapPartitionsRDD [57170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57171 [id="node_57171" labelType="html" label="MapPartitionsRDD [57171] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148327 {
id="cluster_148327";
isCluster="true";
label="WholeStageCodegen (1)";
57172 [id="node_57172" labelType="html" label="MapPartitionsRDD [57172] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148335 {
id="cluster_148335";
isCluster="true";
label="InMemoryTableScan";
57173 [id="node_57173" labelType="html" label="MapPartitionsRDD [57173] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57174 [id="node_57174" labelType="html" label="MapPartitionsRDD [57174] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57175 [id="node_57175" labelType="html" label="MapPartitionsRDD [57175] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148332 {
id="cluster_148332";
isCluster="true";
label="WholeStageCodegen (2)";
57176 [id="node_57176" labelType="html" label="MapPartitionsRDD [57176] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148326 {
id="cluster_148326";
isCluster="true";
label="Union";
57177 [id="node_57177" labelType="html" label="UnionRDD [57177] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148302 {
id="cluster_148302";
isCluster="true";
label="WholeStageCodegen (5)";
57178 [id="node_57178" labelType="html" label="MapPartitionsRDD [57178] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148301 {
id="cluster_148301";
isCluster="true";
label="InMemoryTableScan";
57179 [id="node_57179" labelType="html" label="MapPartitionsRDD [57179] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57180 [id="node_57180" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1148722, qty#1100464, demandChannel#1145353, demandStream#1145354, kpis#1145388]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1148819, worklistShardItemId#1148820L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1145353, demandStream#1145354, kpis#1145388]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1145356 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1145353, demandStream#1145354, isNewlyCalculated#1145356, kpis#1145388, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1145356, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [57180] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57181 [id="node_57181" labelType="html" label="MapPartitionsRDD [57181] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57182 [id="node_57182" labelType="html" label="MapPartitionsRDD [57182] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57183 [id="node_57183" labelType="html" label="MapPartitionsRDD [57183] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148300 {
id="cluster_148300";
isCluster="true";
label="CollectLimit";
57184 [id="node_57184" labelType="html" label="MapPartitionsRDD [57184] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57185 [id="node_57185" labelType="html" label="MapPartitionsRDD [57185] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
56993->56994;
57005->57006;
57009->57010;
57006->57011;
57010->57011;
57011->57012;
57012->57013;
57013->57014;
57021->57022;
56994->57023;
57022->57023;
57023->57024;
57014->57025;
57025->57026;
57026->57027;
57027->57028;
57024->57029;
57028->57029;
57029->57030;
57030->57031;
57127->57128;
57128->57129;
57129->57130;
57130->57131;
57031->57169;
57169->57170;
57170->57171;
57171->57172;
57131->57173;
57173->57174;
57174->57175;
57175->57176;
57172->57177;
57176->57177;
57177->57178;
57178->57179;
57179->57180;
57180->57181;
57181->57182;
57182->57183;
57183->57184;
57184->57185;
}
56992,56993
57004,57005
57008,57009
57020,57021
57126,57127
57014
57031
57131
57180
57005
57006
57009
57010
57011
57012
57013
57014
57021
57022
57023
57024
57025
57026
57027
57028
57029
57030
57031
57127
57128
57129
57130
57131
57169
57170
57171
57172
57173
57174
57175
57176
57177
57178
57179
57180
57181
57182
57183
57184
57185