digraph G {
id="graph_105942";
subgraph graph_stage_105942 {
id="graph_stage_105942";
isCluster="true";
label="Stage 105942";
subgraph cluster_133544 {
id="cluster_133544";
isCluster="true";
label="Exchange";
51094 [id="node_51094" labelType="html" label="ShuffledRowRDD [51094] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133541 {
id="cluster_133541";
isCluster="true";
label="WholeStageCodegen (1)";
51095 [id="node_51095" labelType="html" label="MapPartitionsRDD [51095] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133564 {
id="cluster_133564";
isCluster="true";
label="Exchange";
51106 [id="node_51106" labelType="html" label="ShuffledRowRDD [51106] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133561 {
id="cluster_133561";
isCluster="true";
label="WholeStageCodegen (4)";
51107 [id="node_51107" labelType="html" label="MapPartitionsRDD [51107] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133593 {
id="cluster_133593";
isCluster="true";
label="Exchange";
51110 [id="node_51110" labelType="html" label="ShuffledRowRDD [51110] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133590 {
id="cluster_133590";
isCluster="true";
label="WholeStageCodegen (6)";
51111 [id="node_51111" labelType="html" label="MapPartitionsRDD [51111] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133553 {
id="cluster_133553";
isCluster="true";
label="WholeStageCodegen (7)";
51112 [id="node_51112" labelType="html" label="ZippedPartitionsRDD2 [51112] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51113 [id="node_51113" labelType="html" label="MapPartitionsRDD [51113] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133552 {
id="cluster_133552";
isCluster="true";
label="InMemoryTableScan";
51114 [id="node_51114" labelType="html" label="MapPartitionsRDD [51114] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51115 [id="node_51115" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1022460 AS qty#1022462, demandChannel#1022455, demandStream#1022456, cachedKpis#1022461 AS kpis#1022463]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1022459L, cachedShardId#1022458], 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=1676787]\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... [51115] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133550 {
id="cluster_133550";
isCluster="true";
label="Exchange";
51122 [id="node_51122" labelType="html" label="ShuffledRowRDD [51122] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133547 {
id="cluster_133547";
isCluster="true";
label="WholeStageCodegen (4)";
51123 [id="node_51123" labelType="html" label="MapPartitionsRDD [51123] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133533 {
id="cluster_133533";
isCluster="true";
label="WholeStageCodegen (5)";
51124 [id="node_51124" labelType="html" label="ZippedPartitionsRDD2 [51124] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51125 [id="node_51125" labelType="html" label="MapPartitionsRDD [51125] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133615 {
id="cluster_133615";
isCluster="true";
label="InMemoryTableScan";
51126 [id="node_51126" labelType="html" label="MapPartitionsRDD [51126] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51127 [id="node_51127" labelType="html" label="MapPartitionsRDD [51127] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51128 [id="node_51128" labelType="html" label="MapPartitionsRDD [51128] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133612 {
id="cluster_133612";
isCluster="true";
label="WholeStageCodegen (6)";
51129 [id="node_51129" labelType="html" label="MapPartitionsRDD [51129] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133532 {
id="cluster_133532";
isCluster="true";
label="Union";
51130 [id="node_51130" labelType="html" label="UnionRDD [51130] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133531 {
id="cluster_133531";
isCluster="true";
label="InMemoryTableScan";
51131 [id="node_51131" labelType="html" label="MapPartitionsRDD [51131] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51132 [id="node_51132" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1022695, null AS demandStream#1022696, [] AS kpis#1022730, true AS isNewlyCalculated#1022698]\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#1022687, ), isnull(shardId#1022687), coalesce(worklistShardItemId#1022688L, 0), isnull(worklistShardItemId#1022688L), coalesce(version#1022689, 0), isnull(version#1022689), coalesce(product#1022690, ), isnull(product#1022690), coalesce(plant#1022691, ), isnull(plant#1022691), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51132] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133751 {
id="cluster_133751";
isCluster="true";
label="InMemoryTableScan";
51171 [id="node_51171" labelType="html" label="MapPartitionsRDD [51171] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51172 [id="node_51172" labelType="html" label="MapPartitionsRDD [51172] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51173 [id="node_51173" labelType="html" label="MapPartitionsRDD [51173] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133747 {
id="cluster_133747";
isCluster="true";
label="WholeStageCodegen (11)";
51174 [id="node_51174" labelType="html" label="MapPartitionsRDD [51174] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133746 {
id="cluster_133746";
isCluster="true";
label="ObjectHashAggregate";
51175 [id="node_51175" labelType="html" label="MapPartitionsRDD [51175] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133745 {
id="cluster_133745";
isCluster="true";
label="Exchange";
51176 [id="node_51176" labelType="html" label="MapPartitionsRDD [51176] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
51094->51095;
51106->51107;
51110->51111;
51107->51112;
51111->51112;
51112->51113;
51113->51114;
51114->51115;
51122->51123;
51095->51124;
51123->51124;
51124->51125;
51115->51126;
51126->51127;
51127->51128;
51128->51129;
51125->51130;
51129->51130;
51130->51131;
51131->51132;
51132->51171;
51171->51172;
51172->51173;
51173->51174;
51174->51175;
51175->51176;
}
51093,51094
51105,51106
51109,51110
51121,51122
51115
51132