digraph G {
id="graph_112044";
subgraph graph_stage_112044 {
id="graph_stage_112044";
isCluster="true";
label="Stage 112044";
subgraph cluster_139137 {
id="cluster_139137";
isCluster="true";
label="Exchange";
53472 [id="node_53472" labelType="html" label="ShuffledRowRDD [53472] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139134 {
id="cluster_139134";
isCluster="true";
label="WholeStageCodegen (1)";
53473 [id="node_53473" labelType="html" label="MapPartitionsRDD [53473] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139157 {
id="cluster_139157";
isCluster="true";
label="Exchange";
53484 [id="node_53484" labelType="html" label="ShuffledRowRDD [53484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139154 {
id="cluster_139154";
isCluster="true";
label="WholeStageCodegen (4)";
53485 [id="node_53485" labelType="html" label="MapPartitionsRDD [53485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139186 {
id="cluster_139186";
isCluster="true";
label="Exchange";
53488 [id="node_53488" labelType="html" label="ShuffledRowRDD [53488] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139183 {
id="cluster_139183";
isCluster="true";
label="WholeStageCodegen (6)";
53489 [id="node_53489" labelType="html" label="MapPartitionsRDD [53489] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139146 {
id="cluster_139146";
isCluster="true";
label="WholeStageCodegen (7)";
53490 [id="node_53490" labelType="html" label="ZippedPartitionsRDD2 [53490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53491 [id="node_53491" labelType="html" label="MapPartitionsRDD [53491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139145 {
id="cluster_139145";
isCluster="true";
label="InMemoryTableScan";
53492 [id="node_53492" labelType="html" label="MapPartitionsRDD [53492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53493 [id="node_53493" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1072650 AS qty#1072652, demandChannel#1072645, demandStream#1072646, cachedKpis#1072651 AS kpis#1072653]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1072649L, cachedShardId#1072648], 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=1691032]\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... [53493] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139143 {
id="cluster_139143";
isCluster="true";
label="Exchange";
53500 [id="node_53500" labelType="html" label="ShuffledRowRDD [53500] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139140 {
id="cluster_139140";
isCluster="true";
label="WholeStageCodegen (4)";
53501 [id="node_53501" labelType="html" label="MapPartitionsRDD [53501] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139126 {
id="cluster_139126";
isCluster="true";
label="WholeStageCodegen (5)";
53502 [id="node_53502" labelType="html" label="ZippedPartitionsRDD2 [53502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53503 [id="node_53503" labelType="html" label="MapPartitionsRDD [53503] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139201 {
id="cluster_139201";
isCluster="true";
label="InMemoryTableScan";
53504 [id="node_53504" labelType="html" label="MapPartitionsRDD [53504] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53505 [id="node_53505" labelType="html" label="MapPartitionsRDD [53505] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53506 [id="node_53506" labelType="html" label="MapPartitionsRDD [53506] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139198 {
id="cluster_139198";
isCluster="true";
label="WholeStageCodegen (6)";
53507 [id="node_53507" labelType="html" label="MapPartitionsRDD [53507] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139125 {
id="cluster_139125";
isCluster="true";
label="Union";
53508 [id="node_53508" labelType="html" label="UnionRDD [53508] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139124 {
id="cluster_139124";
isCluster="true";
label="InMemoryTableScan";
53509 [id="node_53509" labelType="html" label="MapPartitionsRDD [53509] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53510 [id="node_53510" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1072885, null AS demandStream#1072886, [] AS kpis#1072920, true AS isNewlyCalculated#1072888]\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#1072877, ), isnull(shardId#1072877), coalesce(worklistShardItemId#1072878L, 0), isnull(worklistShardItemId#1072878L), coalesce(version#1072879, 0), isnull(version#1072879), coalesce(product#1072880, ), isnull(product#1072880), coalesce(plant#1072881, ), isnull(plant#1072881), knownfloatingpointnormalized(normalizenanandzero(coalesce... [53510] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139335 {
id="cluster_139335";
isCluster="true";
label="Exchange";
53555 [id="node_53555" labelType="html" label="ShuffledRowRDD [53555] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139334 {
id="cluster_139334";
isCluster="true";
label="ObjectHashAggregate";
53556 [id="node_53556" labelType="html" label="MapPartitionsRDD [53556] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139346 {
id="cluster_139346";
isCluster="true";
label="InMemoryTableScan";
53557 [id="node_53557" labelType="html" label="MapPartitionsRDD [53557] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53558 [id="node_53558" labelType="html" label="MapPartitionsRDD [53558] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53559 [id="node_53559" labelType="html" label="MapPartitionsRDD [53559] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139342 {
id="cluster_139342";
isCluster="true";
label="WholeStageCodegen (12)";
53560 [id="node_53560" labelType="html" label="MapPartitionsRDD [53560] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139333 {
id="cluster_139333";
isCluster="true";
label="Union";
53561 [id="node_53561" labelType="html" label="UnionRDD [53561] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139332 {
id="cluster_139332";
isCluster="true";
label="Exchange";
53562 [id="node_53562" labelType="html" label="MapPartitionsRDD [53562] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
53472->53473;
53484->53485;
53488->53489;
53485->53490;
53489->53490;
53490->53491;
53491->53492;
53492->53493;
53500->53501;
53473->53502;
53501->53502;
53502->53503;
53493->53504;
53504->53505;
53505->53506;
53506->53507;
53503->53508;
53507->53508;
53508->53509;
53509->53510;
53555->53556;
53510->53557;
53557->53558;
53558->53559;
53559->53560;
53556->53561;
53560->53561;
53561->53562;
}
53471,53472
53483,53484
53487,53488
53499,53500
53554,53555
53493
53510
53484
53485
53488
53489
53490
53491
53492
53493
53500
53501
53502
53503
53504
53505
53506
53507
53508
53509
53510
53555
53556
53557
53558
53559
53560
53561
53562