digraph G {
id="graph_115988";
subgraph graph_stage_115988 {
id="graph_stage_115988";
isCluster="true";
label="Stage 115988";
subgraph cluster_145409 {
id="cluster_145409";
isCluster="true";
label="Exchange";
55935 [id="node_55935" labelType="html" label="ShuffledRowRDD [55935] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145406 {
id="cluster_145406";
isCluster="true";
label="WholeStageCodegen (1)";
55936 [id="node_55936" labelType="html" label="MapPartitionsRDD [55936] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145429 {
id="cluster_145429";
isCluster="true";
label="Exchange";
55947 [id="node_55947" labelType="html" label="ShuffledRowRDD [55947] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145426 {
id="cluster_145426";
isCluster="true";
label="WholeStageCodegen (4)";
55948 [id="node_55948" labelType="html" label="MapPartitionsRDD [55948] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145452 {
id="cluster_145452";
isCluster="true";
label="Exchange";
55951 [id="node_55951" labelType="html" label="ShuffledRowRDD [55951] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145449 {
id="cluster_145449";
isCluster="true";
label="WholeStageCodegen (6)";
55952 [id="node_55952" labelType="html" label="MapPartitionsRDD [55952] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145418 {
id="cluster_145418";
isCluster="true";
label="WholeStageCodegen (7)";
55953 [id="node_55953" labelType="html" label="ZippedPartitionsRDD2 [55953] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55954 [id="node_55954" labelType="html" label="MapPartitionsRDD [55954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145417 {
id="cluster_145417";
isCluster="true";
label="InMemoryTableScan";
55955 [id="node_55955" labelType="html" label="MapPartitionsRDD [55955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55956 [id="node_55956" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1122886 AS qty#1122888, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887 AS kpis#1122889]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1122885L, cachedShardId#1122884], 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=1753792]\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... [55956] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145415 {
id="cluster_145415";
isCluster="true";
label="Exchange";
55963 [id="node_55963" labelType="html" label="ShuffledRowRDD [55963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145412 {
id="cluster_145412";
isCluster="true";
label="WholeStageCodegen (4)";
55964 [id="node_55964" labelType="html" label="MapPartitionsRDD [55964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145398 {
id="cluster_145398";
isCluster="true";
label="WholeStageCodegen (5)";
55965 [id="node_55965" labelType="html" label="ZippedPartitionsRDD2 [55965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55966 [id="node_55966" labelType="html" label="MapPartitionsRDD [55966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145479 {
id="cluster_145479";
isCluster="true";
label="InMemoryTableScan";
55967 [id="node_55967" labelType="html" label="MapPartitionsRDD [55967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55968 [id="node_55968" labelType="html" label="MapPartitionsRDD [55968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55969 [id="node_55969" labelType="html" label="MapPartitionsRDD [55969] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145476 {
id="cluster_145476";
isCluster="true";
label="WholeStageCodegen (6)";
55970 [id="node_55970" labelType="html" label="MapPartitionsRDD [55970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145397 {
id="cluster_145397";
isCluster="true";
label="Union";
55971 [id="node_55971" labelType="html" label="UnionRDD [55971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145396 {
id="cluster_145396";
isCluster="true";
label="InMemoryTableScan";
55972 [id="node_55972" labelType="html" label="MapPartitionsRDD [55972] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
55973 [id="node_55973" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1123121, null AS demandStream#1123122, [] AS kpis#1123156, true AS isNewlyCalculated#1123124]\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#1123113, ), isnull(shardId#1123113), coalesce(worklistShardItemId#1123114L, 0), isnull(worklistShardItemId#1123114L), coalesce(version#1123115, 0), isnull(version#1123115), coalesce(product#1123116, ), isnull(product#1123116), coalesce(plant#1123117, ), isnull(plant#1123117), knownfloatingpointnormalized(normalizenanandzero(coalesce... [55973] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145613 {
id="cluster_145613";
isCluster="true";
label="InMemoryTableScan";
56012 [id="node_56012" labelType="html" label="MapPartitionsRDD [56012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
56013 [id="node_56013" labelType="html" label="MapPartitionsRDD [56013] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
56014 [id="node_56014" labelType="html" label="MapPartitionsRDD [56014] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145609 {
id="cluster_145609";
isCluster="true";
label="WholeStageCodegen (11)";
56015 [id="node_56015" labelType="html" label="MapPartitionsRDD [56015] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145608 {
id="cluster_145608";
isCluster="true";
label="ObjectHashAggregate";
56016 [id="node_56016" labelType="html" label="MapPartitionsRDD [56016] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_145607 {
id="cluster_145607";
isCluster="true";
label="Exchange";
56017 [id="node_56017" labelType="html" label="MapPartitionsRDD [56017] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
55935->55936;
55947->55948;
55951->55952;
55948->55953;
55952->55953;
55953->55954;
55954->55955;
55955->55956;
55963->55964;
55936->55965;
55964->55965;
55965->55966;
55956->55967;
55967->55968;
55968->55969;
55969->55970;
55966->55971;
55970->55971;
55971->55972;
55972->55973;
55973->56012;
56012->56013;
56013->56014;
56014->56015;
56015->56016;
56016->56017;
}
55934,55935
55946,55947
55950,55951
55962,55963
55956
55973
55947
55948
55951
55952
55953
55954
55955
55956
55963
55964
55965
55966
55967
55968
55969
55970
55971
55972
55973
56012
56013
56014
56015
56016
56017