digraph G {
id="graph_102911";
subgraph graph_stage_102911 {
id="graph_stage_102911";
isCluster="true";
label="Stage 102911";
subgraph cluster_129135 {
id="cluster_129135";
isCluster="true";
label="Exchange";
49455 [id="node_49455" labelType="html" label="ShuffledRowRDD [49455] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129132 {
id="cluster_129132";
isCluster="true";
label="WholeStageCodegen (1)";
49456 [id="node_49456" labelType="html" label="MapPartitionsRDD [49456] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129155 {
id="cluster_129155";
isCluster="true";
label="Exchange";
49467 [id="node_49467" labelType="html" label="ShuffledRowRDD [49467] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129152 {
id="cluster_129152";
isCluster="true";
label="WholeStageCodegen (4)";
49468 [id="node_49468" labelType="html" label="MapPartitionsRDD [49468] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129190 {
id="cluster_129190";
isCluster="true";
label="Exchange";
49471 [id="node_49471" labelType="html" label="ShuffledRowRDD [49471] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129187 {
id="cluster_129187";
isCluster="true";
label="WholeStageCodegen (6)";
49472 [id="node_49472" labelType="html" label="MapPartitionsRDD [49472] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129144 {
id="cluster_129144";
isCluster="true";
label="WholeStageCodegen (7)";
49473 [id="node_49473" labelType="html" label="ZippedPartitionsRDD2 [49473] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49474 [id="node_49474" labelType="html" label="MapPartitionsRDD [49474] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129143 {
id="cluster_129143";
isCluster="true";
label="InMemoryTableScan";
49475 [id="node_49475" labelType="html" label="MapPartitionsRDD [49475] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49476 [id="node_49476" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#989865 AS qty#989867, demandChannel#989860, demandStream#989861, cachedKpis#989866 AS kpis#989868]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#989864L, cachedShardId#989863], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1627300]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1627296]\n : +- *(2) Has... [49476] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129141 {
id="cluster_129141";
isCluster="true";
label="Exchange";
49483 [id="node_49483" labelType="html" label="ShuffledRowRDD [49483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129138 {
id="cluster_129138";
isCluster="true";
label="WholeStageCodegen (4)";
49484 [id="node_49484" labelType="html" label="MapPartitionsRDD [49484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129124 {
id="cluster_129124";
isCluster="true";
label="WholeStageCodegen (5)";
49485 [id="node_49485" labelType="html" label="ZippedPartitionsRDD2 [49485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49486 [id="node_49486" labelType="html" label="MapPartitionsRDD [49486] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129205 {
id="cluster_129205";
isCluster="true";
label="InMemoryTableScan";
49487 [id="node_49487" labelType="html" label="MapPartitionsRDD [49487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49488 [id="node_49488" labelType="html" label="MapPartitionsRDD [49488] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49489 [id="node_49489" labelType="html" label="MapPartitionsRDD [49489] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129202 {
id="cluster_129202";
isCluster="true";
label="WholeStageCodegen (6)";
49490 [id="node_49490" labelType="html" label="MapPartitionsRDD [49490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129123 {
id="cluster_129123";
isCluster="true";
label="Union";
49491 [id="node_49491" labelType="html" label="UnionRDD [49491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129122 {
id="cluster_129122";
isCluster="true";
label="InMemoryTableScan";
49492 [id="node_49492" labelType="html" label="MapPartitionsRDD [49492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49493 [id="node_49493" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#990100, null AS demandStream#990101, [] AS kpis#990135, true AS isNewlyCalculated#990103]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#990092, ), isnull(shardId#990092), coalesce(worklistShardItemId#990093L, 0), isnull(worklistShardItemId#990093L), coalesce(version#990094, 0), isnull(version#990094), coalesce(product#990095, ), isnull(product#990095), coalesce(plant#990096, ), isnull(plant#990096), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#989867, 0.0))), isnull(qty#... [49493] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129333 {
id="cluster_129333";
isCluster="true";
label="Exchange";
49538 [id="node_49538" labelType="html" label="ShuffledRowRDD [49538] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129332 {
id="cluster_129332";
isCluster="true";
label="ObjectHashAggregate";
49539 [id="node_49539" labelType="html" label="MapPartitionsRDD [49539] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129344 {
id="cluster_129344";
isCluster="true";
label="InMemoryTableScan";
49540 [id="node_49540" labelType="html" label="MapPartitionsRDD [49540] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49541 [id="node_49541" labelType="html" label="MapPartitionsRDD [49541] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49542 [id="node_49542" labelType="html" label="MapPartitionsRDD [49542] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129340 {
id="cluster_129340";
isCluster="true";
label="WholeStageCodegen (12)";
49543 [id="node_49543" labelType="html" label="MapPartitionsRDD [49543] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129331 {
id="cluster_129331";
isCluster="true";
label="Union";
49544 [id="node_49544" labelType="html" label="UnionRDD [49544] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129330 {
id="cluster_129330";
isCluster="true";
label="Exchange";
49545 [id="node_49545" labelType="html" label="MapPartitionsRDD [49545] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
49455->49456;
49467->49468;
49471->49472;
49468->49473;
49472->49473;
49473->49474;
49474->49475;
49475->49476;
49483->49484;
49456->49485;
49484->49485;
49485->49486;
49476->49487;
49487->49488;
49488->49489;
49489->49490;
49486->49491;
49490->49491;
49491->49492;
49492->49493;
49538->49539;
49493->49540;
49540->49541;
49541->49542;
49542->49543;
49539->49544;
49543->49544;
49544->49545;
}
49454,49455
49466,49467
49470,49471
49482,49483
49537,49538
49476
49493
49467
49468
49471
49472
49473
49474
49475
49476
49483
49484
49485
49486
49487
49488
49489
49490
49491
49492
49493
49538
49539
49540
49541
49542
49543
49544
49545