digraph G {
id="graph_118172";
subgraph graph_stage_118172 {
id="graph_stage_118172";
isCluster="true";
label="Stage 118172";
subgraph cluster_148516 {
id="cluster_148516";
isCluster="true";
label="Exchange";
57257 [id="node_57257" labelType="html" label="ShuffledRowRDD [57257] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148513 {
id="cluster_148513";
isCluster="true";
label="WholeStageCodegen (1)";
57258 [id="node_57258" labelType="html" label="MapPartitionsRDD [57258] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148536 {
id="cluster_148536";
isCluster="true";
label="Exchange";
57269 [id="node_57269" labelType="html" label="ShuffledRowRDD [57269] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148533 {
id="cluster_148533";
isCluster="true";
label="WholeStageCodegen (4)";
57270 [id="node_57270" labelType="html" label="MapPartitionsRDD [57270] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148565 {
id="cluster_148565";
isCluster="true";
label="Exchange";
57273 [id="node_57273" labelType="html" label="ShuffledRowRDD [57273] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148562 {
id="cluster_148562";
isCluster="true";
label="WholeStageCodegen (6)";
57274 [id="node_57274" labelType="html" label="MapPartitionsRDD [57274] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148525 {
id="cluster_148525";
isCluster="true";
label="WholeStageCodegen (7)";
57275 [id="node_57275" labelType="html" label="ZippedPartitionsRDD2 [57275] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57276 [id="node_57276" labelType="html" label="MapPartitionsRDD [57276] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148524 {
id="cluster_148524";
isCluster="true";
label="InMemoryTableScan";
57277 [id="node_57277" labelType="html" label="MapPartitionsRDD [57277] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57278 [id="node_57278" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1150676 AS qty#1150678, demandChannel#1150671, demandStream#1150672, cachedKpis#1150677 AS kpis#1150679]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1150675L, cachedShardId#1150674], 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=1761686]\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... [57278] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148522 {
id="cluster_148522";
isCluster="true";
label="Exchange";
57285 [id="node_57285" labelType="html" label="ShuffledRowRDD [57285] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148519 {
id="cluster_148519";
isCluster="true";
label="WholeStageCodegen (4)";
57286 [id="node_57286" labelType="html" label="MapPartitionsRDD [57286] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148505 {
id="cluster_148505";
isCluster="true";
label="WholeStageCodegen (5)";
57287 [id="node_57287" labelType="html" label="ZippedPartitionsRDD2 [57287] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57288 [id="node_57288" labelType="html" label="MapPartitionsRDD [57288] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148580 {
id="cluster_148580";
isCluster="true";
label="InMemoryTableScan";
57289 [id="node_57289" labelType="html" label="MapPartitionsRDD [57289] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57290 [id="node_57290" labelType="html" label="MapPartitionsRDD [57290] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57291 [id="node_57291" labelType="html" label="MapPartitionsRDD [57291] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148577 {
id="cluster_148577";
isCluster="true";
label="WholeStageCodegen (6)";
57292 [id="node_57292" labelType="html" label="MapPartitionsRDD [57292] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148504 {
id="cluster_148504";
isCluster="true";
label="Union";
57293 [id="node_57293" labelType="html" label="UnionRDD [57293] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148503 {
id="cluster_148503";
isCluster="true";
label="InMemoryTableScan";
57294 [id="node_57294" labelType="html" label="MapPartitionsRDD [57294] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57295 [id="node_57295" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1150911, null AS demandStream#1150912, [] AS kpis#1150946, true AS isNewlyCalculated#1150914]\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#1150903, ), isnull(shardId#1150903), coalesce(worklistShardItemId#1150904L, 0), isnull(worklistShardItemId#1150904L), coalesce(version#1150905, 0), isnull(version#1150905), coalesce(product#1150906, ), isnull(product#1150906), coalesce(plant#1150907, ), isnull(plant#1150907), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57295] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148807 {
id="cluster_148807";
isCluster="true";
label="InMemoryTableScan";
57361 [id="node_57361" labelType="html" label="MapPartitionsRDD [57361] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57362 [id="node_57362" labelType="html" label="MapPartitionsRDD [57362] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57363 [id="node_57363" labelType="html" label="MapPartitionsRDD [57363] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148802 {
id="cluster_148802";
isCluster="true";
label="WholeStageCodegen (3)";
57364 [id="node_57364" labelType="html" label="MapPartitionsRDD [57364] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_148801 {
id="cluster_148801";
isCluster="true";
label="Exchange";
57365 [id="node_57365" labelType="html" label="MapPartitionsRDD [57365] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
57257->57258;
57269->57270;
57273->57274;
57270->57275;
57274->57275;
57275->57276;
57276->57277;
57277->57278;
57285->57286;
57258->57287;
57286->57287;
57287->57288;
57278->57289;
57289->57290;
57290->57291;
57291->57292;
57288->57293;
57292->57293;
57293->57294;
57294->57295;
57295->57361;
57361->57362;
57362->57363;
57363->57364;
57364->57365;
}
57256,57257
57268,57269
57272,57273
57284,57285
57278
57295
57269
57270
57273
57274
57275
57276
57277
57278
57285
57286
57287
57288
57289
57290
57291
57292
57293
57294
57295
57361
57362
57363
57364
57365