digraph G {
id="graph_106033";
subgraph graph_stage_106033 {
id="graph_stage_106033";
isCluster="true";
label="Stage 106033";
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_133824 {
id="cluster_133824";
isCluster="true";
label="Exchange";
51228 [id="node_51228" labelType="html" label="ShuffledRowRDD [51228] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133818 {
id="cluster_133818";
isCluster="true";
label="WholeStageCodegen (6)";
51229 [id="node_51229" labelType="html" label="MapPartitionsRDD [51229] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133817 {
id="cluster_133817";
isCluster="true";
label="SortAggregate";
51230 [id="node_51230" labelType="html" label="MapPartitionsRDD [51230] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133816 {
id="cluster_133816";
isCluster="true";
label="InMemoryTableScan";
51231 [id="node_51231" labelType="html" label="MapPartitionsRDD [51231] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51232 [id="node_51232" labelType="html" label="SortAggregate(key=[demandChannel#1025399, shardId#1011815, qty#1025419, worklistShardItemId#1011816L, demandStream#1025400], functions=[first(kpis#1025428, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1025419, demandChannel#1025399, demandStream#1025400, kpis#1025561])\n+- *(6) Sort [demandChannel#1025399 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1025419 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1025400 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1025399, shardId#1011815, qty#1025419, worklistShardItemId#1011816L, demandStream#1025400, 37), ENSURE_REQUIREMENTS, [plan_id=1677779]\n +- SortAggregate(key=[demandChannel#1025399, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1025419)) AS qty#1025419, worklistShardItemId#1011816L, demandStream#1025400], functions=[partial_first(kpis#1025428, false)], output=[demandChannel#1025399, shardId#1011815, qty#1025419, worklistShardItemId#1011816L,... [51232] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133982 {
id="cluster_133982";
isCluster="true";
label="InMemoryTableScan";
51270 [id="node_51270" labelType="html" label="MapPartitionsRDD [51270] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51271 [id="node_51271" labelType="html" label="MapPartitionsRDD [51271] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51272 [id="node_51272" labelType="html" label="MapPartitionsRDD [51272] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133978 {
id="cluster_133978";
isCluster="true";
label="WholeStageCodegen (1)";
51273 [id="node_51273" labelType="html" label="MapPartitionsRDD [51273] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133986 {
id="cluster_133986";
isCluster="true";
label="InMemoryTableScan";
51274 [id="node_51274" labelType="html" label="MapPartitionsRDD [51274] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51275 [id="node_51275" labelType="html" label="MapPartitionsRDD [51275] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51276 [id="node_51276" labelType="html" label="MapPartitionsRDD [51276] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133983 {
id="cluster_133983";
isCluster="true";
label="WholeStageCodegen (2)";
51277 [id="node_51277" labelType="html" label="MapPartitionsRDD [51277] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133977 {
id="cluster_133977";
isCluster="true";
label="Union";
51278 [id="node_51278" labelType="html" label="UnionRDD [51278] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133953 {
id="cluster_133953";
isCluster="true";
label="WholeStageCodegen (5)";
51279 [id="node_51279" labelType="html" label="MapPartitionsRDD [51279] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133952 {
id="cluster_133952";
isCluster="true";
label="InMemoryTableScan";
51280 [id="node_51280" labelType="html" label="MapPartitionsRDD [51280] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51281 [id="node_51281" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1026232, qty#1011822, demandChannel#1022695, demandStream#1022696, kpis#1022730]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1026329, worklistShardItemId#1026330L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1022695, demandStream#1022696, kpis#1022730]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1022698 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1022695, demandStream#1022696, isNewlyCalculated#1022698, kpis#1022730, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1022698, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [51281] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51282 [id="node_51282" labelType="html" label="MapPartitionsRDD [51282] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51283 [id="node_51283" labelType="html" label="MapPartitionsRDD [51283] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51284 [id="node_51284" labelType="html" label="MapPartitionsRDD [51284] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_133951 {
id="cluster_133951";
isCluster="true";
label="CollectLimit";
51285 [id="node_51285" labelType="html" label="MapPartitionsRDD [51285] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
51286 [id="node_51286" labelType="html" label="MapPartitionsRDD [51286] [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;
51228->51229;
51229->51230;
51230->51231;
51231->51232;
51132->51270;
51270->51271;
51271->51272;
51272->51273;
51232->51274;
51274->51275;
51275->51276;
51276->51277;
51273->51278;
51277->51278;
51278->51279;
51279->51280;
51280->51281;
51281->51282;
51282->51283;
51283->51284;
51284->51285;
51285->51286;
}
51093,51094
51105,51106
51109,51110
51121,51122
51227,51228
51115
51132
51232
51281