digraph G {
id="graph_119620";
subgraph graph_stage_119620 {
id="graph_stage_119620";
isCluster="true";
label="Stage 119620";
subgraph cluster_149758 {
id="cluster_149758";
isCluster="true";
label="Exchange";
57785 [id="node_57785" labelType="html" label="ShuffledRowRDD [57785] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149755 {
id="cluster_149755";
isCluster="true";
label="WholeStageCodegen (1)";
57786 [id="node_57786" labelType="html" label="MapPartitionsRDD [57786] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149778 {
id="cluster_149778";
isCluster="true";
label="Exchange";
57797 [id="node_57797" labelType="html" label="ShuffledRowRDD [57797] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149775 {
id="cluster_149775";
isCluster="true";
label="WholeStageCodegen (4)";
57798 [id="node_57798" labelType="html" label="MapPartitionsRDD [57798] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149807 {
id="cluster_149807";
isCluster="true";
label="Exchange";
57801 [id="node_57801" labelType="html" label="ShuffledRowRDD [57801] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149804 {
id="cluster_149804";
isCluster="true";
label="WholeStageCodegen (6)";
57802 [id="node_57802" labelType="html" label="MapPartitionsRDD [57802] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149767 {
id="cluster_149767";
isCluster="true";
label="WholeStageCodegen (7)";
57803 [id="node_57803" labelType="html" label="ZippedPartitionsRDD2 [57803] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57804 [id="node_57804" labelType="html" label="MapPartitionsRDD [57804] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149766 {
id="cluster_149766";
isCluster="true";
label="InMemoryTableScan";
57805 [id="node_57805" labelType="html" label="MapPartitionsRDD [57805] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57806 [id="node_57806" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1161792 AS qty#1161794, demandChannel#1161787, demandStream#1161788, cachedKpis#1161793 AS kpis#1161795]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1161791L, cachedShardId#1161790], 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=1764825]\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... [57806] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149764 {
id="cluster_149764";
isCluster="true";
label="Exchange";
57813 [id="node_57813" labelType="html" label="ShuffledRowRDD [57813] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149761 {
id="cluster_149761";
isCluster="true";
label="WholeStageCodegen (4)";
57814 [id="node_57814" labelType="html" label="MapPartitionsRDD [57814] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149747 {
id="cluster_149747";
isCluster="true";
label="WholeStageCodegen (5)";
57815 [id="node_57815" labelType="html" label="ZippedPartitionsRDD2 [57815] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57816 [id="node_57816" labelType="html" label="MapPartitionsRDD [57816] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149822 {
id="cluster_149822";
isCluster="true";
label="InMemoryTableScan";
57817 [id="node_57817" labelType="html" label="MapPartitionsRDD [57817] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57818 [id="node_57818" labelType="html" label="MapPartitionsRDD [57818] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57819 [id="node_57819" labelType="html" label="MapPartitionsRDD [57819] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149819 {
id="cluster_149819";
isCluster="true";
label="WholeStageCodegen (6)";
57820 [id="node_57820" labelType="html" label="MapPartitionsRDD [57820] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149746 {
id="cluster_149746";
isCluster="true";
label="Union";
57821 [id="node_57821" labelType="html" label="UnionRDD [57821] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149745 {
id="cluster_149745";
isCluster="true";
label="InMemoryTableScan";
57822 [id="node_57822" labelType="html" label="MapPartitionsRDD [57822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57823 [id="node_57823" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1162027, null AS demandStream#1162028, [] AS kpis#1162062, true AS isNewlyCalculated#1162030]\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#1162019, ), isnull(shardId#1162019), coalesce(worklistShardItemId#1162020L, 0), isnull(worklistShardItemId#1162020L), coalesce(version#1162021, 0), isnull(version#1162021), coalesce(product#1162022, ), isnull(product#1162022), coalesce(plant#1162023, ), isnull(plant#1162023), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57823] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149962 {
id="cluster_149962";
isCluster="true";
label="InMemoryTableScan";
57862 [id="node_57862" labelType="html" label="MapPartitionsRDD [57862] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57863 [id="node_57863" labelType="html" label="MapPartitionsRDD [57863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
57864 [id="node_57864" labelType="html" label="MapPartitionsRDD [57864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149958 {
id="cluster_149958";
isCluster="true";
label="WholeStageCodegen (11)";
57865 [id="node_57865" labelType="html" label="MapPartitionsRDD [57865] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149957 {
id="cluster_149957";
isCluster="true";
label="ObjectHashAggregate";
57866 [id="node_57866" labelType="html" label="MapPartitionsRDD [57866] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_149956 {
id="cluster_149956";
isCluster="true";
label="Exchange";
57867 [id="node_57867" labelType="html" label="MapPartitionsRDD [57867] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
57785->57786;
57797->57798;
57801->57802;
57798->57803;
57802->57803;
57803->57804;
57804->57805;
57805->57806;
57813->57814;
57786->57815;
57814->57815;
57815->57816;
57806->57817;
57817->57818;
57818->57819;
57819->57820;
57816->57821;
57820->57821;
57821->57822;
57822->57823;
57823->57862;
57862->57863;
57863->57864;
57864->57865;
57865->57866;
57866->57867;
}
57784,57785
57796,57797
57800,57801
57812,57813
57806
57823
57797
57798
57801
57802
57803
57804
57805
57806
57813
57814
57815
57816
57817
57818
57819
57820
57821
57822
57823
57862
57863
57864
57865
57866
57867