digraph G {
id="graph_113586";
subgraph graph_stage_113586 {
id="graph_stage_113586";
isCluster="true";
label="Stage 113586";
subgraph cluster_141057 {
id="cluster_141057";
isCluster="true";
label="Exchange";
54286 [id="node_54286" labelType="html" label="ShuffledRowRDD [54286] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141054 {
id="cluster_141054";
isCluster="true";
label="WholeStageCodegen (1)";
54287 [id="node_54287" labelType="html" label="MapPartitionsRDD [54287] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141077 {
id="cluster_141077";
isCluster="true";
label="Exchange";
54298 [id="node_54298" labelType="html" label="ShuffledRowRDD [54298] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141074 {
id="cluster_141074";
isCluster="true";
label="WholeStageCodegen (4)";
54299 [id="node_54299" labelType="html" label="MapPartitionsRDD [54299] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141106 {
id="cluster_141106";
isCluster="true";
label="Exchange";
54302 [id="node_54302" labelType="html" label="ShuffledRowRDD [54302] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141103 {
id="cluster_141103";
isCluster="true";
label="WholeStageCodegen (6)";
54303 [id="node_54303" labelType="html" label="MapPartitionsRDD [54303] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141066 {
id="cluster_141066";
isCluster="true";
label="WholeStageCodegen (7)";
54304 [id="node_54304" labelType="html" label="ZippedPartitionsRDD2 [54304] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54305 [id="node_54305" labelType="html" label="MapPartitionsRDD [54305] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141065 {
id="cluster_141065";
isCluster="true";
label="InMemoryTableScan";
54306 [id="node_54306" labelType="html" label="MapPartitionsRDD [54306] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54307 [id="node_54307" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1089623 AS qty#1089625, demandChannel#1089618, demandStream#1089619, cachedKpis#1089624 AS kpis#1089626]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1089622L, cachedShardId#1089621], 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=1695832]\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... [54307] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141063 {
id="cluster_141063";
isCluster="true";
label="Exchange";
54314 [id="node_54314" labelType="html" label="ShuffledRowRDD [54314] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141060 {
id="cluster_141060";
isCluster="true";
label="WholeStageCodegen (4)";
54315 [id="node_54315" labelType="html" label="MapPartitionsRDD [54315] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141046 {
id="cluster_141046";
isCluster="true";
label="WholeStageCodegen (5)";
54316 [id="node_54316" labelType="html" label="ZippedPartitionsRDD2 [54316] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54317 [id="node_54317" labelType="html" label="MapPartitionsRDD [54317] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141121 {
id="cluster_141121";
isCluster="true";
label="InMemoryTableScan";
54318 [id="node_54318" labelType="html" label="MapPartitionsRDD [54318] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54319 [id="node_54319" labelType="html" label="MapPartitionsRDD [54319] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54320 [id="node_54320" labelType="html" label="MapPartitionsRDD [54320] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141118 {
id="cluster_141118";
isCluster="true";
label="WholeStageCodegen (6)";
54321 [id="node_54321" labelType="html" label="MapPartitionsRDD [54321] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141045 {
id="cluster_141045";
isCluster="true";
label="Union";
54322 [id="node_54322" labelType="html" label="UnionRDD [54322] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141044 {
id="cluster_141044";
isCluster="true";
label="InMemoryTableScan";
54323 [id="node_54323" labelType="html" label="MapPartitionsRDD [54323] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54324 [id="node_54324" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1089858, null AS demandStream#1089859, [] AS kpis#1089893, true AS isNewlyCalculated#1089861]\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#1089850, ), isnull(shardId#1089850), coalesce(worklistShardItemId#1089851L, 0), isnull(worklistShardItemId#1089851L), coalesce(version#1089852, 0), isnull(version#1089852), coalesce(product#1089853, ), isnull(product#1089853), coalesce(plant#1089854, ), isnull(plant#1089854), knownfloatingpointnormalized(normalizenanandzero(coalesce... [54324] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141261 {
id="cluster_141261";
isCluster="true";
label="InMemoryTableScan";
54363 [id="node_54363" labelType="html" label="MapPartitionsRDD [54363] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54364 [id="node_54364" labelType="html" label="MapPartitionsRDD [54364] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
54365 [id="node_54365" labelType="html" label="MapPartitionsRDD [54365] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141257 {
id="cluster_141257";
isCluster="true";
label="WholeStageCodegen (11)";
54366 [id="node_54366" labelType="html" label="MapPartitionsRDD [54366] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141256 {
id="cluster_141256";
isCluster="true";
label="ObjectHashAggregate";
54367 [id="node_54367" labelType="html" label="MapPartitionsRDD [54367] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_141255 {
id="cluster_141255";
isCluster="true";
label="Exchange";
54368 [id="node_54368" labelType="html" label="MapPartitionsRDD [54368] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
54286->54287;
54298->54299;
54302->54303;
54299->54304;
54303->54304;
54304->54305;
54305->54306;
54306->54307;
54314->54315;
54287->54316;
54315->54316;
54316->54317;
54307->54318;
54318->54319;
54319->54320;
54320->54321;
54317->54322;
54321->54322;
54322->54323;
54323->54324;
54324->54363;
54363->54364;
54364->54365;
54365->54366;
54366->54367;
54367->54368;
}
54285,54286
54297,54298
54301,54302
54313,54314
54307
54324
54298
54299
54302
54303
54304
54305
54306
54307
54314
54315
54316
54317
54318
54319
54320
54321
54322
54323
54324
54363
54364
54365
54366
54367
54368