digraph G {
id="graph_118866";
subgraph graph_stage_118866 {
id="graph_stage_118866";
isCluster="true";
label="Stage 118866";
subgraph cluster_149137 {
id="cluster_149137";
isCluster="true";
label="Exchange";
57521 [id="node_57521" labelType="html" label="ShuffledRowRDD [57521] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149134 {
id="cluster_149134";
isCluster="true";
label="WholeStageCodegen (1)";
57522 [id="node_57522" labelType="html" label="MapPartitionsRDD [57522] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149157 {
id="cluster_149157";
isCluster="true";
label="Exchange";
57533 [id="node_57533" labelType="html" label="ShuffledRowRDD [57533] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149154 {
id="cluster_149154";
isCluster="true";
label="WholeStageCodegen (4)";
57534 [id="node_57534" labelType="html" label="MapPartitionsRDD [57534] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149186 {
id="cluster_149186";
isCluster="true";
label="Exchange";
57537 [id="node_57537" labelType="html" label="ShuffledRowRDD [57537] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149183 {
id="cluster_149183";
isCluster="true";
label="WholeStageCodegen (6)";
57538 [id="node_57538" labelType="html" label="MapPartitionsRDD [57538] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149146 {
id="cluster_149146";
isCluster="true";
label="WholeStageCodegen (7)";
57539 [id="node_57539" labelType="html" label="ZippedPartitionsRDD2 [57539] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57540 [id="node_57540" labelType="html" label="MapPartitionsRDD [57540] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149145 {
id="cluster_149145";
isCluster="true";
label="InMemoryTableScan";
57541 [id="node_57541" labelType="html" label="MapPartitionsRDD [57541] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57542 [id="node_57542" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1156234 AS qty#1156236, demandChannel#1156229, demandStream#1156230, cachedKpis#1156235 AS kpis#1156237]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1156233L, cachedShardId#1156232], 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=1763276]\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... [57542] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149143 {
id="cluster_149143";
isCluster="true";
label="Exchange";
57549 [id="node_57549" labelType="html" label="ShuffledRowRDD [57549] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149140 {
id="cluster_149140";
isCluster="true";
label="WholeStageCodegen (4)";
57550 [id="node_57550" labelType="html" label="MapPartitionsRDD [57550] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149126 {
id="cluster_149126";
isCluster="true";
label="WholeStageCodegen (5)";
57551 [id="node_57551" labelType="html" label="ZippedPartitionsRDD2 [57551] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57552 [id="node_57552" labelType="html" label="MapPartitionsRDD [57552] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149207 {
id="cluster_149207";
isCluster="true";
label="InMemoryTableScan";
57553 [id="node_57553" labelType="html" label="MapPartitionsRDD [57553] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57554 [id="node_57554" labelType="html" label="MapPartitionsRDD [57554] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57555 [id="node_57555" labelType="html" label="MapPartitionsRDD [57555] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149204 {
id="cluster_149204";
isCluster="true";
label="WholeStageCodegen (6)";
57556 [id="node_57556" labelType="html" label="MapPartitionsRDD [57556] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149125 {
id="cluster_149125";
isCluster="true";
label="Union";
57557 [id="node_57557" labelType="html" label="UnionRDD [57557] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149124 {
id="cluster_149124";
isCluster="true";
label="InMemoryTableScan";
57558 [id="node_57558" labelType="html" label="MapPartitionsRDD [57558] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57559 [id="node_57559" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1156469, null AS demandStream#1156470, [] AS kpis#1156504, true AS isNewlyCalculated#1156472]\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#1156461, ), isnull(shardId#1156461), coalesce(worklistShardItemId#1156462L, 0), isnull(worklistShardItemId#1156462L), coalesce(version#1156463, 0), isnull(version#1156463), coalesce(product#1156464, ), isnull(product#1156464), coalesce(plant#1156465, ), isnull(plant#1156465), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57559] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149428 {
id="cluster_149428";
isCluster="true";
label="InMemoryTableScan";
57625 [id="node_57625" labelType="html" label="MapPartitionsRDD [57625] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57626 [id="node_57626" labelType="html" label="MapPartitionsRDD [57626] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57627 [id="node_57627" labelType="html" label="MapPartitionsRDD [57627] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149423 {
id="cluster_149423";
isCluster="true";
label="WholeStageCodegen (3)";
57628 [id="node_57628" labelType="html" label="MapPartitionsRDD [57628] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149422 {
id="cluster_149422";
isCluster="true";
label="Exchange";
57629 [id="node_57629" labelType="html" label="MapPartitionsRDD [57629] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
57521->57522;
57533->57534;
57537->57538;
57534->57539;
57538->57539;
57539->57540;
57540->57541;
57541->57542;
57549->57550;
57522->57551;
57550->57551;
57551->57552;
57542->57553;
57553->57554;
57554->57555;
57555->57556;
57552->57557;
57556->57557;
57557->57558;
57558->57559;
57559->57625;
57625->57626;
57626->57627;
57627->57628;
57628->57629;
}
57520,57521
57532,57533
57536,57537
57548,57549
57542
57559
57533
57534
57537
57538
57539
57540
57541
57542
57549
57550
57551
57552
57553
57554
57555
57556
57557
57558
57559
57625
57626
57627
57628
57629