digraph G {
id="graph_107675";
subgraph graph_stage_107675 {
id="graph_stage_107675";
isCluster="true";
label="Stage 107675";
subgraph cluster_136030 {
id="cluster_136030";
isCluster="true";
label="Exchange";
52150 [id="node_52150" labelType="html" label="ShuffledRowRDD [52150] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136027 {
id="cluster_136027";
isCluster="true";
label="WholeStageCodegen (1)";
52151 [id="node_52151" labelType="html" label="MapPartitionsRDD [52151] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136050 {
id="cluster_136050";
isCluster="true";
label="Exchange";
52162 [id="node_52162" labelType="html" label="ShuffledRowRDD [52162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136047 {
id="cluster_136047";
isCluster="true";
label="WholeStageCodegen (4)";
52163 [id="node_52163" labelType="html" label="MapPartitionsRDD [52163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136079 {
id="cluster_136079";
isCluster="true";
label="Exchange";
52166 [id="node_52166" labelType="html" label="ShuffledRowRDD [52166] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136076 {
id="cluster_136076";
isCluster="true";
label="WholeStageCodegen (6)";
52167 [id="node_52167" labelType="html" label="MapPartitionsRDD [52167] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136039 {
id="cluster_136039";
isCluster="true";
label="WholeStageCodegen (7)";
52168 [id="node_52168" labelType="html" label="ZippedPartitionsRDD2 [52168] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52169 [id="node_52169" labelType="html" label="MapPartitionsRDD [52169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136038 {
id="cluster_136038";
isCluster="true";
label="InMemoryTableScan";
52170 [id="node_52170" labelType="html" label="MapPartitionsRDD [52170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52171 [id="node_52171" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1044860 AS qty#1044862, demandChannel#1044855, demandStream#1044856, cachedKpis#1044861 AS kpis#1044863]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1044859L, cachedShardId#1044858], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1683138]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [52171] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136036 {
id="cluster_136036";
isCluster="true";
label="Exchange";
52178 [id="node_52178" labelType="html" label="ShuffledRowRDD [52178] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136033 {
id="cluster_136033";
isCluster="true";
label="WholeStageCodegen (4)";
52179 [id="node_52179" labelType="html" label="MapPartitionsRDD [52179] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136019 {
id="cluster_136019";
isCluster="true";
label="WholeStageCodegen (5)";
52180 [id="node_52180" labelType="html" label="ZippedPartitionsRDD2 [52180] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52181 [id="node_52181" labelType="html" label="MapPartitionsRDD [52181] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136100 {
id="cluster_136100";
isCluster="true";
label="InMemoryTableScan";
52182 [id="node_52182" labelType="html" label="MapPartitionsRDD [52182] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52183 [id="node_52183" labelType="html" label="MapPartitionsRDD [52183] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52184 [id="node_52184" labelType="html" label="MapPartitionsRDD [52184] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136097 {
id="cluster_136097";
isCluster="true";
label="WholeStageCodegen (6)";
52185 [id="node_52185" labelType="html" label="MapPartitionsRDD [52185] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136018 {
id="cluster_136018";
isCluster="true";
label="Union";
52186 [id="node_52186" labelType="html" label="UnionRDD [52186] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136017 {
id="cluster_136017";
isCluster="true";
label="InMemoryTableScan";
52187 [id="node_52187" labelType="html" label="MapPartitionsRDD [52187] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52188 [id="node_52188" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1045095, null AS demandStream#1045096, [] AS kpis#1045130, true AS isNewlyCalculated#1045098]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1045087, ), isnull(shardId#1045087), coalesce(worklistShardItemId#1045088L, 0), isnull(worklistShardItemId#1045088L), coalesce(version#1045089, 0), isnull(version#1045089), coalesce(product#1045090, ), isnull(product#1045090), coalesce(plant#1045091, ), isnull(plant#1045091), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52188] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136228 {
id="cluster_136228";
isCluster="true";
label="Exchange";
52233 [id="node_52233" labelType="html" label="ShuffledRowRDD [52233] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136227 {
id="cluster_136227";
isCluster="true";
label="ObjectHashAggregate";
52234 [id="node_52234" labelType="html" label="MapPartitionsRDD [52234] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136239 {
id="cluster_136239";
isCluster="true";
label="InMemoryTableScan";
52235 [id="node_52235" labelType="html" label="MapPartitionsRDD [52235] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52236 [id="node_52236" labelType="html" label="MapPartitionsRDD [52236] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52237 [id="node_52237" labelType="html" label="MapPartitionsRDD [52237] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136235 {
id="cluster_136235";
isCluster="true";
label="WholeStageCodegen (12)";
52238 [id="node_52238" labelType="html" label="MapPartitionsRDD [52238] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136226 {
id="cluster_136226";
isCluster="true";
label="Union";
52239 [id="node_52239" labelType="html" label="UnionRDD [52239] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_136225 {
id="cluster_136225";
isCluster="true";
label="Exchange";
52240 [id="node_52240" labelType="html" label="MapPartitionsRDD [52240] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
52150->52151;
52162->52163;
52166->52167;
52163->52168;
52167->52168;
52168->52169;
52169->52170;
52170->52171;
52178->52179;
52151->52180;
52179->52180;
52180->52181;
52171->52182;
52182->52183;
52183->52184;
52184->52185;
52181->52186;
52185->52186;
52186->52187;
52187->52188;
52233->52234;
52188->52235;
52235->52236;
52236->52237;
52237->52238;
52234->52239;
52238->52239;
52239->52240;
}
52149,52150
52161,52162
52165,52166
52177,52178
52232,52233
52171
52188
52162
52163
52166
52167
52168
52169
52170
52171
52178
52179
52180
52181
52182
52183
52184
52185
52186
52187
52188
52233
52234
52235
52236
52237
52238
52239
52240