digraph G {
id="graph_106998";
subgraph graph_stage_106998 {
id="graph_stage_106998";
isCluster="true";
label="Stage 106998";
subgraph cluster_135409 {
id="cluster_135409";
isCluster="true";
label="Exchange";
51886 [id="node_51886" labelType="html" label="ShuffledRowRDD [51886] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135406 {
id="cluster_135406";
isCluster="true";
label="WholeStageCodegen (1)";
51887 [id="node_51887" labelType="html" label="MapPartitionsRDD [51887] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135429 {
id="cluster_135429";
isCluster="true";
label="Exchange";
51898 [id="node_51898" labelType="html" label="ShuffledRowRDD [51898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135426 {
id="cluster_135426";
isCluster="true";
label="WholeStageCodegen (4)";
51899 [id="node_51899" labelType="html" label="MapPartitionsRDD [51899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135458 {
id="cluster_135458";
isCluster="true";
label="Exchange";
51902 [id="node_51902" labelType="html" label="ShuffledRowRDD [51902] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135455 {
id="cluster_135455";
isCluster="true";
label="WholeStageCodegen (6)";
51903 [id="node_51903" labelType="html" label="MapPartitionsRDD [51903] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135418 {
id="cluster_135418";
isCluster="true";
label="WholeStageCodegen (7)";
51904 [id="node_51904" labelType="html" label="ZippedPartitionsRDD2 [51904] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51905 [id="node_51905" labelType="html" label="MapPartitionsRDD [51905] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135417 {
id="cluster_135417";
isCluster="true";
label="InMemoryTableScan";
51906 [id="node_51906" labelType="html" label="MapPartitionsRDD [51906] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51907 [id="node_51907" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1039302 AS qty#1039304, demandChannel#1039297, demandStream#1039298, cachedKpis#1039303 AS kpis#1039305]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1039301L, cachedShardId#1039300], 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=1681589]\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... [51907] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135415 {
id="cluster_135415";
isCluster="true";
label="Exchange";
51914 [id="node_51914" labelType="html" label="ShuffledRowRDD [51914] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135412 {
id="cluster_135412";
isCluster="true";
label="WholeStageCodegen (4)";
51915 [id="node_51915" labelType="html" label="MapPartitionsRDD [51915] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135398 {
id="cluster_135398";
isCluster="true";
label="WholeStageCodegen (5)";
51916 [id="node_51916" labelType="html" label="ZippedPartitionsRDD2 [51916] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51917 [id="node_51917" labelType="html" label="MapPartitionsRDD [51917] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135473 {
id="cluster_135473";
isCluster="true";
label="InMemoryTableScan";
51918 [id="node_51918" labelType="html" label="MapPartitionsRDD [51918] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51919 [id="node_51919" labelType="html" label="MapPartitionsRDD [51919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51920 [id="node_51920" labelType="html" label="MapPartitionsRDD [51920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135470 {
id="cluster_135470";
isCluster="true";
label="WholeStageCodegen (6)";
51921 [id="node_51921" labelType="html" label="MapPartitionsRDD [51921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135397 {
id="cluster_135397";
isCluster="true";
label="Union";
51922 [id="node_51922" labelType="html" label="UnionRDD [51922] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135396 {
id="cluster_135396";
isCluster="true";
label="InMemoryTableScan";
51923 [id="node_51923" labelType="html" label="MapPartitionsRDD [51923] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51924 [id="node_51924" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1039537, null AS demandStream#1039538, [] AS kpis#1039572, true AS isNewlyCalculated#1039540]\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#1039529, ), isnull(shardId#1039529), coalesce(worklistShardItemId#1039530L, 0), isnull(worklistShardItemId#1039530L), coalesce(version#1039531, 0), isnull(version#1039531), coalesce(product#1039532, ), isnull(product#1039532), coalesce(plant#1039533, ), isnull(plant#1039533), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51924] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135613 {
id="cluster_135613";
isCluster="true";
label="InMemoryTableScan";
51963 [id="node_51963" labelType="html" label="MapPartitionsRDD [51963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51964 [id="node_51964" labelType="html" label="MapPartitionsRDD [51964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51965 [id="node_51965" labelType="html" label="MapPartitionsRDD [51965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135609 {
id="cluster_135609";
isCluster="true";
label="WholeStageCodegen (11)";
51966 [id="node_51966" labelType="html" label="MapPartitionsRDD [51966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135608 {
id="cluster_135608";
isCluster="true";
label="ObjectHashAggregate";
51967 [id="node_51967" labelType="html" label="MapPartitionsRDD [51967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135607 {
id="cluster_135607";
isCluster="true";
label="Exchange";
51968 [id="node_51968" labelType="html" label="MapPartitionsRDD [51968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
51886->51887;
51898->51899;
51902->51903;
51899->51904;
51903->51904;
51904->51905;
51905->51906;
51906->51907;
51914->51915;
51887->51916;
51915->51916;
51916->51917;
51907->51918;
51918->51919;
51919->51920;
51920->51921;
51917->51922;
51921->51922;
51922->51923;
51923->51924;
51924->51963;
51963->51964;
51964->51965;
51965->51966;
51966->51967;
51967->51968;
}
51885,51886
51897,51898
51901,51902
51913,51914
51907
51924
51898
51899
51902
51903
51904
51905
51906
51907
51914
51915
51916
51917
51918
51919
51920
51921
51922
51923
51924
51963
51964
51965
51966
51967
51968