digraph G {
id="graph_115635";
subgraph graph_stage_115635 {
id="graph_stage_115635";
isCluster="true";
label="Stage 115635";
subgraph cluster_144777 {
id="cluster_144777";
isCluster="true";
label="Exchange";
55667 [id="node_55667" labelType="html" label="ShuffledRowRDD [55667] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144774 {
id="cluster_144774";
isCluster="true";
label="WholeStageCodegen (1)";
55668 [id="node_55668" labelType="html" label="MapPartitionsRDD [55668] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144797 {
id="cluster_144797";
isCluster="true";
label="Exchange";
55679 [id="node_55679" labelType="html" label="ShuffledRowRDD [55679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144794 {
id="cluster_144794";
isCluster="true";
label="WholeStageCodegen (4)";
55680 [id="node_55680" labelType="html" label="MapPartitionsRDD [55680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144832 {
id="cluster_144832";
isCluster="true";
label="Exchange";
55683 [id="node_55683" labelType="html" label="ShuffledRowRDD [55683] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144829 {
id="cluster_144829";
isCluster="true";
label="WholeStageCodegen (6)";
55684 [id="node_55684" labelType="html" label="MapPartitionsRDD [55684] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144786 {
id="cluster_144786";
isCluster="true";
label="WholeStageCodegen (7)";
55685 [id="node_55685" labelType="html" label="ZippedPartitionsRDD2 [55685] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55686 [id="node_55686" labelType="html" label="MapPartitionsRDD [55686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144785 {
id="cluster_144785";
isCluster="true";
label="InMemoryTableScan";
55687 [id="node_55687" labelType="html" label="MapPartitionsRDD [55687] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55688 [id="node_55688" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1117306 AS qty#1117308, demandChannel#1117301, demandStream#1117302, cachedKpis#1117307 AS kpis#1117309]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1117305L, cachedShardId#1117304], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1752232]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [55688] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144783 {
id="cluster_144783";
isCluster="true";
label="Exchange";
55695 [id="node_55695" labelType="html" label="ShuffledRowRDD [55695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144780 {
id="cluster_144780";
isCluster="true";
label="WholeStageCodegen (4)";
55696 [id="node_55696" labelType="html" label="MapPartitionsRDD [55696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144766 {
id="cluster_144766";
isCluster="true";
label="WholeStageCodegen (5)";
55697 [id="node_55697" labelType="html" label="ZippedPartitionsRDD2 [55697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55698 [id="node_55698" labelType="html" label="MapPartitionsRDD [55698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144847 {
id="cluster_144847";
isCluster="true";
label="InMemoryTableScan";
55699 [id="node_55699" labelType="html" label="MapPartitionsRDD [55699] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55700 [id="node_55700" labelType="html" label="MapPartitionsRDD [55700] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55701 [id="node_55701" labelType="html" label="MapPartitionsRDD [55701] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144844 {
id="cluster_144844";
isCluster="true";
label="WholeStageCodegen (6)";
55702 [id="node_55702" labelType="html" label="MapPartitionsRDD [55702] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144765 {
id="cluster_144765";
isCluster="true";
label="Union";
55703 [id="node_55703" labelType="html" label="UnionRDD [55703] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144764 {
id="cluster_144764";
isCluster="true";
label="InMemoryTableScan";
55704 [id="node_55704" labelType="html" label="MapPartitionsRDD [55704] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55705 [id="node_55705" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1117541, null AS demandStream#1117542, [] AS kpis#1117576, true AS isNewlyCalculated#1117544]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1117533, ), isnull(shardId#1117533), coalesce(worklistShardItemId#1117534L, 0), isnull(worklistShardItemId#1117534L), coalesce(version#1117535, 0), isnull(version#1117535), coalesce(product#1117536, ), isnull(product#1117536), coalesce(plant#1117537, ), isnull(plant#1117537), knownfloatingpointnormalized(normalizenanandzero(coalesce... [55705] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144981 {
id="cluster_144981";
isCluster="true";
label="InMemoryTableScan";
55744 [id="node_55744" labelType="html" label="MapPartitionsRDD [55744] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55745 [id="node_55745" labelType="html" label="MapPartitionsRDD [55745] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55746 [id="node_55746" labelType="html" label="MapPartitionsRDD [55746] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144977 {
id="cluster_144977";
isCluster="true";
label="WholeStageCodegen (11)";
55747 [id="node_55747" labelType="html" label="MapPartitionsRDD [55747] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144976 {
id="cluster_144976";
isCluster="true";
label="ObjectHashAggregate";
55748 [id="node_55748" labelType="html" label="MapPartitionsRDD [55748] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144975 {
id="cluster_144975";
isCluster="true";
label="Exchange";
55749 [id="node_55749" labelType="html" label="MapPartitionsRDD [55749] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
55667->55668;
55679->55680;
55683->55684;
55680->55685;
55684->55685;
55685->55686;
55686->55687;
55687->55688;
55695->55696;
55668->55697;
55696->55697;
55697->55698;
55688->55699;
55699->55700;
55700->55701;
55701->55702;
55698->55703;
55702->55703;
55703->55704;
55704->55705;
55705->55744;
55744->55745;
55745->55746;
55746->55747;
55747->55748;
55748->55749;
}
55666,55667
55678,55679
55682,55683
55694,55695
55688
55705
55679
55680
55683
55684
55685
55686
55687
55688
55695
55696
55697
55698
55699
55700
55701
55702
55703
55704
55705
55744
55745
55746
55747
55748
55749