digraph G {
id="graph_118785";
subgraph graph_stage_118785 {
id="graph_stage_118785";
isCluster="true";
label="Stage 118785";
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_149335 {
id="cluster_149335";
isCluster="true";
label="Exchange";
57604 [id="node_57604" labelType="html" label="ShuffledRowRDD [57604] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149334 {
id="cluster_149334";
isCluster="true";
label="ObjectHashAggregate";
57605 [id="node_57605" labelType="html" label="MapPartitionsRDD [57605] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149346 {
id="cluster_149346";
isCluster="true";
label="InMemoryTableScan";
57606 [id="node_57606" labelType="html" label="MapPartitionsRDD [57606] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57607 [id="node_57607" labelType="html" label="MapPartitionsRDD [57607] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57608 [id="node_57608" labelType="html" label="MapPartitionsRDD [57608] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149342 {
id="cluster_149342";
isCluster="true";
label="WholeStageCodegen (12)";
57609 [id="node_57609" labelType="html" label="MapPartitionsRDD [57609] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149333 {
id="cluster_149333";
isCluster="true";
label="Union";
57610 [id="node_57610" labelType="html" label="UnionRDD [57610] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149332 {
id="cluster_149332";
isCluster="true";
label="Exchange";
57611 [id="node_57611" labelType="html" label="MapPartitionsRDD [57611] [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;
57604->57605;
57559->57606;
57606->57607;
57607->57608;
57608->57609;
57605->57610;
57609->57610;
57610->57611;
}
57520,57521
57532,57533
57536,57537
57548,57549
57603,57604
57542
57559
57533
57534
57537
57538
57539
57540
57541
57542
57549
57550
57551
57552
57553
57554
57555
57556
57557
57558
57559
57604
57605
57606
57607
57608
57609
57610
57611