digraph G {
id="graph_111376";
subgraph graph_stage_111376 {
id="graph_stage_111376";
isCluster="true";
label="Stage 111376";
subgraph cluster_137893 {
id="cluster_137893";
isCluster="true";
label="Exchange";
52942 [id="node_52942" labelType="html" label="ShuffledRowRDD [52942] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137890 {
id="cluster_137890";
isCluster="true";
label="WholeStageCodegen (1)";
52943 [id="node_52943" labelType="html" label="MapPartitionsRDD [52943] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137913 {
id="cluster_137913";
isCluster="true";
label="Exchange";
52954 [id="node_52954" labelType="html" label="ShuffledRowRDD [52954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137910 {
id="cluster_137910";
isCluster="true";
label="WholeStageCodegen (4)";
52955 [id="node_52955" labelType="html" label="MapPartitionsRDD [52955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137942 {
id="cluster_137942";
isCluster="true";
label="Exchange";
52958 [id="node_52958" labelType="html" label="ShuffledRowRDD [52958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137939 {
id="cluster_137939";
isCluster="true";
label="WholeStageCodegen (6)";
52959 [id="node_52959" labelType="html" label="MapPartitionsRDD [52959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137902 {
id="cluster_137902";
isCluster="true";
label="WholeStageCodegen (7)";
52960 [id="node_52960" labelType="html" label="ZippedPartitionsRDD2 [52960] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52961 [id="node_52961" labelType="html" label="MapPartitionsRDD [52961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137901 {
id="cluster_137901";
isCluster="true";
label="InMemoryTableScan";
52962 [id="node_52962" labelType="html" label="MapPartitionsRDD [52962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52963 [id="node_52963" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1061534 AS qty#1061536, demandChannel#1061529, demandStream#1061530, cachedKpis#1061535 AS kpis#1061537]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1061533L, cachedShardId#1061532], 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=1687852]\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... [52963] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137899 {
id="cluster_137899";
isCluster="true";
label="Exchange";
52970 [id="node_52970" labelType="html" label="ShuffledRowRDD [52970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137896 {
id="cluster_137896";
isCluster="true";
label="WholeStageCodegen (4)";
52971 [id="node_52971" labelType="html" label="MapPartitionsRDD [52971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137882 {
id="cluster_137882";
isCluster="true";
label="WholeStageCodegen (5)";
52972 [id="node_52972" labelType="html" label="ZippedPartitionsRDD2 [52972] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52973 [id="node_52973" labelType="html" label="MapPartitionsRDD [52973] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137957 {
id="cluster_137957";
isCluster="true";
label="InMemoryTableScan";
52974 [id="node_52974" labelType="html" label="MapPartitionsRDD [52974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52975 [id="node_52975" labelType="html" label="MapPartitionsRDD [52975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52976 [id="node_52976" labelType="html" label="MapPartitionsRDD [52976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137954 {
id="cluster_137954";
isCluster="true";
label="WholeStageCodegen (6)";
52977 [id="node_52977" labelType="html" label="MapPartitionsRDD [52977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137881 {
id="cluster_137881";
isCluster="true";
label="Union";
52978 [id="node_52978" labelType="html" label="UnionRDD [52978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137880 {
id="cluster_137880";
isCluster="true";
label="InMemoryTableScan";
52979 [id="node_52979" labelType="html" label="MapPartitionsRDD [52979] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52980 [id="node_52980" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1061769, null AS demandStream#1061770, [] AS kpis#1061804, true AS isNewlyCalculated#1061772]\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#1061761, ), isnull(shardId#1061761), coalesce(worklistShardItemId#1061762L, 0), isnull(worklistShardItemId#1061762L), coalesce(version#1061763, 0), isnull(version#1061763), coalesce(product#1061764, ), isnull(product#1061764), coalesce(plant#1061765, ), isnull(plant#1061765), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52980] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138313 {
id="cluster_138313";
isCluster="true";
label="InMemoryTableScan";
53110 [id="node_53110" labelType="html" label="MapPartitionsRDD [53110] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53111 [id="node_53111" labelType="html" label="MapPartitionsRDD [53111] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53112 [id="node_53112" labelType="html" label="MapPartitionsRDD [53112] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138309 {
id="cluster_138309";
isCluster="true";
label="WholeStageCodegen (3)";
53113 [id="node_53113" labelType="html" label="MapPartitionsRDD [53113] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138308 {
id="cluster_138308";
isCluster="true";
label="Exchange";
53114 [id="node_53114" labelType="html" label="MapPartitionsRDD [53114] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
52942->52943;
52954->52955;
52958->52959;
52955->52960;
52959->52960;
52960->52961;
52961->52962;
52962->52963;
52970->52971;
52943->52972;
52971->52972;
52972->52973;
52963->52974;
52974->52975;
52975->52976;
52976->52977;
52973->52978;
52977->52978;
52978->52979;
52979->52980;
52980->53110;
53110->53111;
53111->53112;
53112->53113;
53113->53114;
}
52941,52942
52953,52954
52957,52958
52969,52970
52963
52980
52954
52955
52958
52959
52960
52961
52962
52963
52970
52971
52972
52973
52974
52975
52976
52977
52978
52979
52980
53110
53111
53112
53113
53114