digraph G {
id="graph_99490";
subgraph graph_stage_99490 {
id="graph_stage_99490";
isCluster="true";
label="Stage 99490";
subgraph cluster_119215 {
id="cluster_119215";
isCluster="true";
label="Exchange";
45851 [id="node_45851" labelType="html" label="ShuffledRowRDD [45851] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119212 {
id="cluster_119212";
isCluster="true";
label="WholeStageCodegen (1)";
45852 [id="node_45852" labelType="html" label="MapPartitionsRDD [45852] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119235 {
id="cluster_119235";
isCluster="true";
label="Exchange";
45863 [id="node_45863" labelType="html" label="ShuffledRowRDD [45863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119232 {
id="cluster_119232";
isCluster="true";
label="WholeStageCodegen (4)";
45864 [id="node_45864" labelType="html" label="MapPartitionsRDD [45864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119270 {
id="cluster_119270";
isCluster="true";
label="Exchange";
45867 [id="node_45867" labelType="html" label="ShuffledRowRDD [45867] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119267 {
id="cluster_119267";
isCluster="true";
label="WholeStageCodegen (6)";
45868 [id="node_45868" labelType="html" label="MapPartitionsRDD [45868] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119224 {
id="cluster_119224";
isCluster="true";
label="WholeStageCodegen (7)";
45869 [id="node_45869" labelType="html" label="ZippedPartitionsRDD2 [45869] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45870 [id="node_45870" labelType="html" label="MapPartitionsRDD [45870] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119223 {
id="cluster_119223";
isCluster="true";
label="InMemoryTableScan";
45871 [id="node_45871" labelType="html" label="MapPartitionsRDD [45871] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45872 [id="node_45872" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#921681 AS qty#921683, demandChannel#921676, demandStream#921677, cachedKpis#921682 AS kpis#921684]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#921680L, cachedShardId#921679], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1449313]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1449309]\n : +- *(2) Has... [45872] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119221 {
id="cluster_119221";
isCluster="true";
label="Exchange";
45879 [id="node_45879" labelType="html" label="ShuffledRowRDD [45879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119218 {
id="cluster_119218";
isCluster="true";
label="WholeStageCodegen (4)";
45880 [id="node_45880" labelType="html" label="MapPartitionsRDD [45880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119204 {
id="cluster_119204";
isCluster="true";
label="WholeStageCodegen (5)";
45881 [id="node_45881" labelType="html" label="ZippedPartitionsRDD2 [45881] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45882 [id="node_45882" labelType="html" label="MapPartitionsRDD [45882] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119285 {
id="cluster_119285";
isCluster="true";
label="InMemoryTableScan";
45883 [id="node_45883" labelType="html" label="MapPartitionsRDD [45883] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45884 [id="node_45884" labelType="html" label="MapPartitionsRDD [45884] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45885 [id="node_45885" labelType="html" label="MapPartitionsRDD [45885] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119282 {
id="cluster_119282";
isCluster="true";
label="WholeStageCodegen (6)";
45886 [id="node_45886" labelType="html" label="MapPartitionsRDD [45886] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119203 {
id="cluster_119203";
isCluster="true";
label="Union";
45887 [id="node_45887" labelType="html" label="UnionRDD [45887] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119202 {
id="cluster_119202";
isCluster="true";
label="InMemoryTableScan";
45888 [id="node_45888" labelType="html" label="MapPartitionsRDD [45888] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45889 [id="node_45889" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#921916, null AS demandStream#921917, [] AS kpis#921951, true AS isNewlyCalculated#921919]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#921908, ), isnull(shardId#921908), coalesce(worklistShardItemId#921909L, 0), isnull(worklistShardItemId#921909L), coalesce(version#921910, 0), isnull(version#921910), coalesce(product#921911, ), isnull(product#921911), coalesce(plant#921912, ), isnull(plant#921912), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#921683, 0.0))), isnull(qty#... [45889] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119413 {
id="cluster_119413";
isCluster="true";
label="Exchange";
45934 [id="node_45934" labelType="html" label="ShuffledRowRDD [45934] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119412 {
id="cluster_119412";
isCluster="true";
label="ObjectHashAggregate";
45935 [id="node_45935" labelType="html" label="MapPartitionsRDD [45935] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119424 {
id="cluster_119424";
isCluster="true";
label="InMemoryTableScan";
45936 [id="node_45936" labelType="html" label="MapPartitionsRDD [45936] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45937 [id="node_45937" labelType="html" label="MapPartitionsRDD [45937] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
45938 [id="node_45938" labelType="html" label="MapPartitionsRDD [45938] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119420 {
id="cluster_119420";
isCluster="true";
label="WholeStageCodegen (12)";
45939 [id="node_45939" labelType="html" label="MapPartitionsRDD [45939] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119411 {
id="cluster_119411";
isCluster="true";
label="Union";
45940 [id="node_45940" labelType="html" label="UnionRDD [45940] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119410 {
id="cluster_119410";
isCluster="true";
label="Exchange";
45941 [id="node_45941" labelType="html" label="MapPartitionsRDD [45941] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
45851->45852;
45863->45864;
45867->45868;
45864->45869;
45868->45869;
45869->45870;
45870->45871;
45871->45872;
45879->45880;
45852->45881;
45880->45881;
45881->45882;
45872->45883;
45883->45884;
45884->45885;
45885->45886;
45882->45887;
45886->45887;
45887->45888;
45888->45889;
45934->45935;
45889->45936;
45936->45937;
45937->45938;
45938->45939;
45935->45940;
45939->45940;
45940->45941;
}
45850,45851
45862,45863
45866,45867
45878,45879
45933,45934
45872
45889
45863
45864
45867
45868
45869
45870
45871
45872
45879
45880
45881
45882
45883
45884
45885
45886
45887
45888
45889
45934
45935
45936
45937
45938
45939
45940
45941