digraph G {
id="graph_101599";
subgraph graph_stage_101599 {
id="graph_stage_101599";
isCluster="true";
label="Stage 101599";
subgraph cluster_126649 {
id="cluster_126649";
isCluster="true";
label="Exchange";
48397 [id="node_48397" labelType="html" label="ShuffledRowRDD [48397] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126646 {
id="cluster_126646";
isCluster="true";
label="WholeStageCodegen (1)";
48398 [id="node_48398" labelType="html" label="MapPartitionsRDD [48398] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126668 {
id="cluster_126668";
isCluster="true";
label="Exchange";
48409 [id="node_48409" labelType="html" label="ShuffledRowRDD [48409] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126665 {
id="cluster_126665";
isCluster="true";
label="WholeStageCodegen (4)";
48410 [id="node_48410" labelType="html" label="MapPartitionsRDD [48410] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126704 {
id="cluster_126704";
isCluster="true";
label="Exchange";
48413 [id="node_48413" labelType="html" label="ShuffledRowRDD [48413] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126701 {
id="cluster_126701";
isCluster="true";
label="WholeStageCodegen (6)";
48414 [id="node_48414" labelType="html" label="MapPartitionsRDD [48414] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126658 {
id="cluster_126658";
isCluster="true";
label="WholeStageCodegen (7)";
48415 [id="node_48415" labelType="html" label="ZippedPartitionsRDD2 [48415] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48416 [id="node_48416" labelType="html" label="MapPartitionsRDD [48416] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126657 {
id="cluster_126657";
isCluster="true";
label="InMemoryTableScan";
48417 [id="node_48417" labelType="html" label="MapPartitionsRDD [48417] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48418 [id="node_48418" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#967633 AS qty#967635, demandChannel#967628, demandStream#967629, cachedKpis#967634 AS kpis#967636]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#967632L, cachedShardId#967631], 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=1620955]\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=1620951]\n : +- *(2) Has... [48418] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126655 {
id="cluster_126655";
isCluster="true";
label="Exchange";
48425 [id="node_48425" labelType="html" label="ShuffledRowRDD [48425] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126652 {
id="cluster_126652";
isCluster="true";
label="WholeStageCodegen (4)";
48426 [id="node_48426" labelType="html" label="MapPartitionsRDD [48426] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126638 {
id="cluster_126638";
isCluster="true";
label="WholeStageCodegen (5)";
48427 [id="node_48427" labelType="html" label="ZippedPartitionsRDD2 [48427] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48428 [id="node_48428" labelType="html" label="MapPartitionsRDD [48428] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126719 {
id="cluster_126719";
isCluster="true";
label="InMemoryTableScan";
48429 [id="node_48429" labelType="html" label="MapPartitionsRDD [48429] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48430 [id="node_48430" labelType="html" label="MapPartitionsRDD [48430] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48431 [id="node_48431" labelType="html" label="MapPartitionsRDD [48431] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126716 {
id="cluster_126716";
isCluster="true";
label="WholeStageCodegen (6)";
48432 [id="node_48432" labelType="html" label="MapPartitionsRDD [48432] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126637 {
id="cluster_126637";
isCluster="true";
label="Union";
48433 [id="node_48433" labelType="html" label="UnionRDD [48433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126636 {
id="cluster_126636";
isCluster="true";
label="InMemoryTableScan";
48434 [id="node_48434" labelType="html" label="MapPartitionsRDD [48434] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48435 [id="node_48435" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#967868, null AS demandStream#967869, [] AS kpis#967903, true AS isNewlyCalculated#967871]\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#967860, ), isnull(shardId#967860), coalesce(worklistShardItemId#967861L, 0), isnull(worklistShardItemId#967861L), coalesce(version#967862, 0), isnull(version#967862), coalesce(product#967863, ), isnull(product#967863), coalesce(plant#967864, ), isnull(plant#967864), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#967635, 0.0))), isnull(qty#... [48435] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126847 {
id="cluster_126847";
isCluster="true";
label="Exchange";
48480 [id="node_48480" labelType="html" label="ShuffledRowRDD [48480] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126846 {
id="cluster_126846";
isCluster="true";
label="ObjectHashAggregate";
48481 [id="node_48481" labelType="html" label="MapPartitionsRDD [48481] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126858 {
id="cluster_126858";
isCluster="true";
label="InMemoryTableScan";
48482 [id="node_48482" labelType="html" label="MapPartitionsRDD [48482] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48483 [id="node_48483" labelType="html" label="MapPartitionsRDD [48483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48484 [id="node_48484" labelType="html" label="MapPartitionsRDD [48484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126854 {
id="cluster_126854";
isCluster="true";
label="WholeStageCodegen (12)";
48485 [id="node_48485" labelType="html" label="MapPartitionsRDD [48485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126845 {
id="cluster_126845";
isCluster="true";
label="Union";
48486 [id="node_48486" labelType="html" label="UnionRDD [48486] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126844 {
id="cluster_126844";
isCluster="true";
label="Exchange";
48487 [id="node_48487" labelType="html" label="MapPartitionsRDD [48487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
48397->48398;
48409->48410;
48413->48414;
48410->48415;
48414->48415;
48415->48416;
48416->48417;
48417->48418;
48425->48426;
48398->48427;
48426->48427;
48427->48428;
48418->48429;
48429->48430;
48430->48431;
48431->48432;
48428->48433;
48432->48433;
48433->48434;
48434->48435;
48480->48481;
48435->48482;
48482->48483;
48483->48484;
48484->48485;
48481->48486;
48485->48486;
48486->48487;
}
48396,48397
48408,48409
48412,48413
48424,48425
48479,48480
48418
48435
48409
48410
48413
48414
48415
48416
48417
48418
48425
48426
48427
48428
48429
48430
48431
48432
48433
48434
48435
48480
48481
48482
48483
48484
48485
48486
48487