digraph G {
id="graph_94227";
subgraph graph_stage_94227 {
id="graph_stage_94227";
isCluster="true";
label="Stage 94227";
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_111996 {
id="cluster_111996";
isCluster="true";
label="Exchange";
42996 [id="node_42996" labelType="html" label="ShuffledRowRDD [42996] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111991 {
id="cluster_111991";
isCluster="true";
label="WholeStageCodegen (6)";
42997 [id="node_42997" labelType="html" label="MapPartitionsRDD [42997] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111990 {
id="cluster_111990";
isCluster="true";
label="SortAggregate";
42998 [id="node_42998" labelType="html" label="MapPartitionsRDD [42998] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_111989 {
id="cluster_111989";
isCluster="true";
label="InMemoryTableScan";
42999 [id="node_42999" labelType="html" label="MapPartitionsRDD [42999] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43000 [id="node_43000" labelType="html" label="SortAggregate(key=[demandChannel#862982, shardId#815740, qty#863002, worklistShardItemId#815741L, demandStream#862983], functions=[first(kpis#863011, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#863002, demandChannel#862982, demandStream#862983, kpis#863144])\n+- *(6) Sort [demandChannel#862982 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#863002 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#862983 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#862982, shardId#815740, qty#863002, worklistShardItemId#815741L, demandStream#862983, 37), ENSURE_REQUIREMENTS, [plan_id=1382517]\n +- SortAggregate(key=[demandChannel#862982, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#863002)) AS qty#863002, worklistShardItemId#815741L, demandStream#862983], functions=[partial_first(kpis#863011, false)], output=[demandChannel#862982, shardId#815740, qty#863002, worklistShardItemId#815741L, demandStream#862983, first#86322... [43000] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112156 {
id="cluster_112156";
isCluster="true";
label="InMemoryTableScan";
43038 [id="node_43038" labelType="html" label="MapPartitionsRDD [43038] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43039 [id="node_43039" labelType="html" label="MapPartitionsRDD [43039] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43040 [id="node_43040" labelType="html" label="MapPartitionsRDD [43040] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112152 {
id="cluster_112152";
isCluster="true";
label="WholeStageCodegen (1)";
43041 [id="node_43041" labelType="html" label="MapPartitionsRDD [43041] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112160 {
id="cluster_112160";
isCluster="true";
label="InMemoryTableScan";
43042 [id="node_43042" labelType="html" label="MapPartitionsRDD [43042] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43043 [id="node_43043" labelType="html" label="MapPartitionsRDD [43043] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43044 [id="node_43044" labelType="html" label="MapPartitionsRDD [43044] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112157 {
id="cluster_112157";
isCluster="true";
label="WholeStageCodegen (2)";
43045 [id="node_43045" labelType="html" label="MapPartitionsRDD [43045] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112151 {
id="cluster_112151";
isCluster="true";
label="Union";
43046 [id="node_43046" labelType="html" label="UnionRDD [43046] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112127 {
id="cluster_112127";
isCluster="true";
label="WholeStageCodegen (5)";
43047 [id="node_43047" labelType="html" label="MapPartitionsRDD [43047] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112126 {
id="cluster_112126";
isCluster="true";
label="InMemoryTableScan";
43048 [id="node_43048" labelType="html" label="MapPartitionsRDD [43048] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43049 [id="node_43049" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#863815, qty#815747, demandChannel#860446, demandStream#860447, kpis#860481]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#863912, worklistShardItemId#863913L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#860446, demandStream#860447, kpis#860481]\n : : +- *(1) Filter ((NOT isNewlyCalculated#860449 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#860446, demandStream#860447, isNewlyCalculated#860449, kpis#860481, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#860449, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#860446, demandStream#860447... [43049] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_112185 {
id="cluster_112185";
isCluster="true";
label="InMemoryTableScan";
43058 [id="node_43058" labelType="html" label="MapPartitionsRDD [43058] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43059 [id="node_43059" labelType="html" label="MapPartitionsRDD [43059] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43060 [id="node_43060" labelType="html" label="MapPartitionsRDD [43060] [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;
42996->42997;
42997->42998;
42998->42999;
42999->43000;
42900->43038;
43038->43039;
43039->43040;
43040->43041;
43000->43042;
43042->43043;
43043->43044;
43044->43045;
43041->43046;
43045->43046;
43046->43047;
43047->43048;
43048->43049;
43049->43058;
43058->43059;
43059->43060;
}
42861,42862
42873,42874
42877,42878
42889,42890
42995,42996
42883
42900
43000
43049
42874
42875
42878
42879
42880
42881
42882
42883
42890
42891
42892
42893
42894
42895
42896
42897
42898
42899
42900
42996
42997
42998
42999
43000
43038
43039
43040
43041
43042
43043
43044
43045
43046
43047
43048
43049
43058
43059
43060