digraph G {
id="graph_93481";
subgraph graph_stage_93481 {
id="graph_stage_93481";
isCluster="true";
label="Stage 93481";
subgraph cluster_111720 {
id="cluster_111720";
isCluster="true";
label="Exchange";
42862 [id="node_42862" labelType="html" label="ShuffledRowRDD [42862] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111717 {
id="cluster_111717";
isCluster="true";
label="WholeStageCodegen (1)";
42863 [id="node_42863" labelType="html" label="MapPartitionsRDD [42863] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111740 {
id="cluster_111740";
isCluster="true";
label="Exchange";
42874 [id="node_42874" labelType="html" label="ShuffledRowRDD [42874] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111737 {
id="cluster_111737";
isCluster="true";
label="WholeStageCodegen (4)";
42875 [id="node_42875" labelType="html" label="MapPartitionsRDD [42875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111775 {
id="cluster_111775";
isCluster="true";
label="Exchange";
42878 [id="node_42878" labelType="html" label="ShuffledRowRDD [42878] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111772 {
id="cluster_111772";
isCluster="true";
label="WholeStageCodegen (6)";
42879 [id="node_42879" labelType="html" label="MapPartitionsRDD [42879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111729 {
id="cluster_111729";
isCluster="true";
label="WholeStageCodegen (7)";
42880 [id="node_42880" labelType="html" label="ZippedPartitionsRDD2 [42880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42881 [id="node_42881" labelType="html" label="MapPartitionsRDD [42881] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111728 {
id="cluster_111728";
isCluster="true";
label="InMemoryTableScan";
42882 [id="node_42882" labelType="html" label="MapPartitionsRDD [42882] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42883 [id="node_42883" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#860211 AS qty#860213, demandChannel#860206, demandStream#860207, cachedKpis#860212 AS kpis#860214]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#860210L, cachedShardId#860209], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1381587]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1381583]\n : +- *(2) Has... [42883] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111726 {
id="cluster_111726";
isCluster="true";
label="Exchange";
42890 [id="node_42890" labelType="html" label="ShuffledRowRDD [42890] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111723 {
id="cluster_111723";
isCluster="true";
label="WholeStageCodegen (4)";
42891 [id="node_42891" labelType="html" label="MapPartitionsRDD [42891] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111709 {
id="cluster_111709";
isCluster="true";
label="WholeStageCodegen (5)";
42892 [id="node_42892" labelType="html" label="ZippedPartitionsRDD2 [42892] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42893 [id="node_42893" labelType="html" label="MapPartitionsRDD [42893] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111790 {
id="cluster_111790";
isCluster="true";
label="InMemoryTableScan";
42894 [id="node_42894" labelType="html" label="MapPartitionsRDD [42894] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42895 [id="node_42895" labelType="html" label="MapPartitionsRDD [42895] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42896 [id="node_42896" labelType="html" label="MapPartitionsRDD [42896] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111787 {
id="cluster_111787";
isCluster="true";
label="WholeStageCodegen (6)";
42897 [id="node_42897" labelType="html" label="MapPartitionsRDD [42897] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111708 {
id="cluster_111708";
isCluster="true";
label="Union";
42898 [id="node_42898" labelType="html" label="UnionRDD [42898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111707 {
id="cluster_111707";
isCluster="true";
label="InMemoryTableScan";
42899 [id="node_42899" labelType="html" label="MapPartitionsRDD [42899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42900 [id="node_42900" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#860446, null AS demandStream#860447, [] AS kpis#860481, true AS isNewlyCalculated#860449]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#860438, ), isnull(shardId#860438), coalesce(worklistShardItemId#860439L, 0), isnull(worklistShardItemId#860439L), coalesce(version#860440, 0), isnull(version#860440), coalesce(product#860441, ), isnull(product#860441), coalesce(plant#860442, ), isnull(plant#860442), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#860213, 0.0))), isnull(qty#... [42900] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112011 {
id="cluster_112011";
isCluster="true";
label="InMemoryTableScan";
42966 [id="node_42966" labelType="html" label="MapPartitionsRDD [42966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42967 [id="node_42967" labelType="html" label="MapPartitionsRDD [42967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42968 [id="node_42968" labelType="html" label="MapPartitionsRDD [42968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112006 {
id="cluster_112006";
isCluster="true";
label="WholeStageCodegen (3)";
42969 [id="node_42969" labelType="html" label="MapPartitionsRDD [42969] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112005 {
id="cluster_112005";
isCluster="true";
label="Exchange";
42970 [id="node_42970" labelType="html" label="MapPartitionsRDD [42970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
42862->42863;
42874->42875;
42878->42879;
42875->42880;
42879->42880;
42880->42881;
42881->42882;
42882->42883;
42890->42891;
42863->42892;
42891->42892;
42892->42893;
42883->42894;
42894->42895;
42895->42896;
42896->42897;
42893->42898;
42897->42898;
42898->42899;
42899->42900;
42900->42966;
42966->42967;
42967->42968;
42968->42969;
42969->42970;
}
42861,42862
42873,42874
42877,42878
42889,42890
42883
42900
42874
42875
42878
42879
42880
42881
42882
42883
42890
42891
42892
42893
42894
42895
42896
42897
42898
42899
42900
42966
42967
42968
42969
42970