digraph G {
id="graph_111664";
subgraph graph_stage_111664 {
id="graph_stage_111664";
isCluster="true";
label="Stage 111664";
subgraph cluster_137893 {
id="cluster_137893";
isCluster="true";
label="Exchange";
52942 [id="node_52942" labelType="html" label="ShuffledRowRDD [52942] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137890 {
id="cluster_137890";
isCluster="true";
label="WholeStageCodegen (1)";
52943 [id="node_52943" labelType="html" label="MapPartitionsRDD [52943] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137913 {
id="cluster_137913";
isCluster="true";
label="Exchange";
52954 [id="node_52954" labelType="html" label="ShuffledRowRDD [52954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137910 {
id="cluster_137910";
isCluster="true";
label="WholeStageCodegen (4)";
52955 [id="node_52955" labelType="html" label="MapPartitionsRDD [52955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137942 {
id="cluster_137942";
isCluster="true";
label="Exchange";
52958 [id="node_52958" labelType="html" label="ShuffledRowRDD [52958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137939 {
id="cluster_137939";
isCluster="true";
label="WholeStageCodegen (6)";
52959 [id="node_52959" labelType="html" label="MapPartitionsRDD [52959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137902 {
id="cluster_137902";
isCluster="true";
label="WholeStageCodegen (7)";
52960 [id="node_52960" labelType="html" label="ZippedPartitionsRDD2 [52960] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52961 [id="node_52961" labelType="html" label="MapPartitionsRDD [52961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137901 {
id="cluster_137901";
isCluster="true";
label="InMemoryTableScan";
52962 [id="node_52962" labelType="html" label="MapPartitionsRDD [52962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52963 [id="node_52963" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1061534 AS qty#1061536, demandChannel#1061529, demandStream#1061530, cachedKpis#1061535 AS kpis#1061537]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1061533L, cachedShardId#1061532], 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=1687852]\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... [52963] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137899 {
id="cluster_137899";
isCluster="true";
label="Exchange";
52970 [id="node_52970" labelType="html" label="ShuffledRowRDD [52970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137896 {
id="cluster_137896";
isCluster="true";
label="WholeStageCodegen (4)";
52971 [id="node_52971" labelType="html" label="MapPartitionsRDD [52971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137882 {
id="cluster_137882";
isCluster="true";
label="WholeStageCodegen (5)";
52972 [id="node_52972" labelType="html" label="ZippedPartitionsRDD2 [52972] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52973 [id="node_52973" labelType="html" label="MapPartitionsRDD [52973] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137957 {
id="cluster_137957";
isCluster="true";
label="InMemoryTableScan";
52974 [id="node_52974" labelType="html" label="MapPartitionsRDD [52974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52975 [id="node_52975" labelType="html" label="MapPartitionsRDD [52975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52976 [id="node_52976" labelType="html" label="MapPartitionsRDD [52976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137954 {
id="cluster_137954";
isCluster="true";
label="WholeStageCodegen (6)";
52977 [id="node_52977" labelType="html" label="MapPartitionsRDD [52977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137881 {
id="cluster_137881";
isCluster="true";
label="Union";
52978 [id="node_52978" labelType="html" label="UnionRDD [52978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_137880 {
id="cluster_137880";
isCluster="true";
label="InMemoryTableScan";
52979 [id="node_52979" labelType="html" label="MapPartitionsRDD [52979] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
52980 [id="node_52980" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1061769, null AS demandStream#1061770, [] AS kpis#1061804, true AS isNewlyCalculated#1061772]\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#1061761, ), isnull(shardId#1061761), coalesce(worklistShardItemId#1061762L, 0), isnull(worklistShardItemId#1061762L), coalesce(version#1061763, 0), isnull(version#1061763), coalesce(product#1061764, ), isnull(product#1061764), coalesce(plant#1061765, ), isnull(plant#1061765), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52980] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138169 {
id="cluster_138169";
isCluster="true";
label="Exchange";
53076 [id="node_53076" labelType="html" label="ShuffledRowRDD [53076] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138164 {
id="cluster_138164";
isCluster="true";
label="WholeStageCodegen (6)";
53077 [id="node_53077" labelType="html" label="MapPartitionsRDD [53077] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138163 {
id="cluster_138163";
isCluster="true";
label="SortAggregate";
53078 [id="node_53078" labelType="html" label="MapPartitionsRDD [53078] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138162 {
id="cluster_138162";
isCluster="true";
label="InMemoryTableScan";
53079 [id="node_53079" labelType="html" label="MapPartitionsRDD [53079] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53080 [id="node_53080" labelType="html" label="SortAggregate(key=[demandChannel#1064305, shardId#1011815, qty#1064325, worklistShardItemId#1011816L, demandStream#1064306], functions=[first(kpis#1064334, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1064325, demandChannel#1064305, demandStream#1064306, kpis#1064467])\n+- *(6) Sort [demandChannel#1064305 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1064325 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1064306 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1064305, shardId#1011815, qty#1064325, worklistShardItemId#1011816L, demandStream#1064306, 37), ENSURE_REQUIREMENTS, [plan_id=1688782]\n +- SortAggregate(key=[demandChannel#1064305, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1064325)) AS qty#1064325, worklistShardItemId#1011816L, demandStream#1064306], functions=[partial_first(kpis#1064334, false)], output=[demandChannel#1064305, shardId#1011815, qty#1064325, worklistShardItemId#1011816L,... [53080] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138329 {
id="cluster_138329";
isCluster="true";
label="InMemoryTableScan";
53118 [id="node_53118" labelType="html" label="MapPartitionsRDD [53118] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53119 [id="node_53119" labelType="html" label="MapPartitionsRDD [53119] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53120 [id="node_53120" labelType="html" label="MapPartitionsRDD [53120] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138325 {
id="cluster_138325";
isCluster="true";
label="WholeStageCodegen (1)";
53121 [id="node_53121" labelType="html" label="MapPartitionsRDD [53121] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138333 {
id="cluster_138333";
isCluster="true";
label="InMemoryTableScan";
53122 [id="node_53122" labelType="html" label="MapPartitionsRDD [53122] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53123 [id="node_53123" labelType="html" label="MapPartitionsRDD [53123] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53124 [id="node_53124" labelType="html" label="MapPartitionsRDD [53124] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138330 {
id="cluster_138330";
isCluster="true";
label="WholeStageCodegen (2)";
53125 [id="node_53125" labelType="html" label="MapPartitionsRDD [53125] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138324 {
id="cluster_138324";
isCluster="true";
label="Union";
53126 [id="node_53126" labelType="html" label="UnionRDD [53126] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138300 {
id="cluster_138300";
isCluster="true";
label="WholeStageCodegen (5)";
53127 [id="node_53127" labelType="html" label="MapPartitionsRDD [53127] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138299 {
id="cluster_138299";
isCluster="true";
label="InMemoryTableScan";
53128 [id="node_53128" labelType="html" label="MapPartitionsRDD [53128] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53129 [id="node_53129" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1065138, qty#1011822, demandChannel#1061769, demandStream#1061770, kpis#1061804]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1065235, worklistShardItemId#1065236L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1061769, demandStream#1061770, kpis#1061804]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1061772 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1061769, demandStream#1061770, isNewlyCalculated#1061772, kpis#1061804, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1061772, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [53129] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_138358 {
id="cluster_138358";
isCluster="true";
label="InMemoryTableScan";
53138 [id="node_53138" labelType="html" label="MapPartitionsRDD [53138] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53139 [id="node_53139" labelType="html" label="MapPartitionsRDD [53139] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53140 [id="node_53140" labelType="html" label="MapPartitionsRDD [53140] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
52942->52943;
52954->52955;
52958->52959;
52955->52960;
52959->52960;
52960->52961;
52961->52962;
52962->52963;
52970->52971;
52943->52972;
52971->52972;
52972->52973;
52963->52974;
52974->52975;
52975->52976;
52976->52977;
52973->52978;
52977->52978;
52978->52979;
52979->52980;
53076->53077;
53077->53078;
53078->53079;
53079->53080;
52980->53118;
53118->53119;
53119->53120;
53120->53121;
53080->53122;
53122->53123;
53123->53124;
53124->53125;
53121->53126;
53125->53126;
53126->53127;
53127->53128;
53128->53129;
53129->53138;
53138->53139;
53139->53140;
}
52941,52942
52953,52954
52957,52958
52969,52970
53075,53076
52963
52980
53080
53129
52954
52955
52958
52959
52960
52961
52962
52963
52970
52971
52972
52973
52974
52975
52976
52977
52978
52979
52980
53076
53077
53078
53079
53080
53118
53119
53120
53121
53122
53123
53124
53125
53126
53127
53128
53129
53138
53139
53140