digraph G {
id="graph_105943";
subgraph graph_stage_105943 {
id="graph_stage_105943";
isCluster="true";
label="Stage 105943";
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_133745 {
id="cluster_133745";
isCluster="true";
label="Exchange";
51177 [id="node_51177" labelType="html" label="ShuffledRowRDD [51177] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133744 {
id="cluster_133744";
isCluster="true";
label="ObjectHashAggregate";
51178 [id="node_51178" labelType="html" label="MapPartitionsRDD [51178] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133756 {
id="cluster_133756";
isCluster="true";
label="InMemoryTableScan";
51179 [id="node_51179" labelType="html" label="MapPartitionsRDD [51179] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51180 [id="node_51180" labelType="html" label="MapPartitionsRDD [51180] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51181 [id="node_51181" labelType="html" label="MapPartitionsRDD [51181] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133752 {
id="cluster_133752";
isCluster="true";
label="WholeStageCodegen (12)";
51182 [id="node_51182" labelType="html" label="MapPartitionsRDD [51182] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133743 {
id="cluster_133743";
isCluster="true";
label="Union";
51183 [id="node_51183" labelType="html" label="UnionRDD [51183] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133742 {
id="cluster_133742";
isCluster="true";
label="Exchange";
51184 [id="node_51184" labelType="html" label="MapPartitionsRDD [51184] [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;
51177->51178;
51132->51179;
51179->51180;
51180->51181;
51181->51182;
51178->51183;
51182->51183;
51183->51184;
}
51093,51094
51105,51106
51109,51110
51121,51122
51176,51177
51115
51132