digraph G {
id="graph_106999";
subgraph graph_stage_106999 {
id="graph_stage_106999";
isCluster="true";
label="Stage 106999";
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_135607 {
id="cluster_135607";
isCluster="true";
label="Exchange";
51969 [id="node_51969" labelType="html" label="ShuffledRowRDD [51969] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135606 {
id="cluster_135606";
isCluster="true";
label="ObjectHashAggregate";
51970 [id="node_51970" labelType="html" label="MapPartitionsRDD [51970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135618 {
id="cluster_135618";
isCluster="true";
label="InMemoryTableScan";
51971 [id="node_51971" labelType="html" label="MapPartitionsRDD [51971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51972 [id="node_51972" labelType="html" label="MapPartitionsRDD [51972] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51973 [id="node_51973" labelType="html" label="MapPartitionsRDD [51973] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135614 {
id="cluster_135614";
isCluster="true";
label="WholeStageCodegen (12)";
51974 [id="node_51974" labelType="html" label="MapPartitionsRDD [51974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135605 {
id="cluster_135605";
isCluster="true";
label="Union";
51975 [id="node_51975" labelType="html" label="UnionRDD [51975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_135604 {
id="cluster_135604";
isCluster="true";
label="Exchange";
51976 [id="node_51976" labelType="html" label="MapPartitionsRDD [51976] [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;
51969->51970;
51924->51971;
51971->51972;
51972->51973;
51973->51974;
51970->51975;
51974->51975;
51975->51976;
}
51885,51886
51897,51898
51901,51902
51913,51914
51968,51969
51907
51924
51898
51899
51902
51903
51904
51905
51906
51907
51914
51915
51916
51917
51918
51919
51920
51921
51922
51923
51924
51969
51970
51971
51972
51973
51974
51975
51976