digraph G {
id="graph_103911";
subgraph graph_stage_103911 {
id="graph_stage_103911";
isCluster="true";
label="Stage 103911";
subgraph cluster_129756 {
id="cluster_129756";
isCluster="true";
label="Exchange";
49719 [id="node_49719" labelType="html" label="ShuffledRowRDD [49719] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129753 {
id="cluster_129753";
isCluster="true";
label="WholeStageCodegen (1)";
49720 [id="node_49720" labelType="html" label="MapPartitionsRDD [49720] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129776 {
id="cluster_129776";
isCluster="true";
label="Exchange";
49731 [id="node_49731" labelType="html" label="ShuffledRowRDD [49731] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129773 {
id="cluster_129773";
isCluster="true";
label="WholeStageCodegen (4)";
49732 [id="node_49732" labelType="html" label="MapPartitionsRDD [49732] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129805 {
id="cluster_129805";
isCluster="true";
label="Exchange";
49735 [id="node_49735" labelType="html" label="ShuffledRowRDD [49735] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129802 {
id="cluster_129802";
isCluster="true";
label="WholeStageCodegen (6)";
49736 [id="node_49736" labelType="html" label="MapPartitionsRDD [49736] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129765 {
id="cluster_129765";
isCluster="true";
label="WholeStageCodegen (7)";
49737 [id="node_49737" labelType="html" label="ZippedPartitionsRDD2 [49737] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49738 [id="node_49738" labelType="html" label="MapPartitionsRDD [49738] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129764 {
id="cluster_129764";
isCluster="true";
label="InMemoryTableScan";
49739 [id="node_49739" labelType="html" label="MapPartitionsRDD [49739] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49740 [id="node_49740" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#995423 AS qty#995425, demandChannel#995418, demandStream#995419, cachedKpis#995424 AS kpis#995426]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#995422L, cachedShardId#995421], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1628890]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1628886]\n : +- *(2) Has... [49740] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129762 {
id="cluster_129762";
isCluster="true";
label="Exchange";
49747 [id="node_49747" labelType="html" label="ShuffledRowRDD [49747] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129759 {
id="cluster_129759";
isCluster="true";
label="WholeStageCodegen (4)";
49748 [id="node_49748" labelType="html" label="MapPartitionsRDD [49748] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129745 {
id="cluster_129745";
isCluster="true";
label="WholeStageCodegen (5)";
49749 [id="node_49749" labelType="html" label="ZippedPartitionsRDD2 [49749] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49750 [id="node_49750" labelType="html" label="MapPartitionsRDD [49750] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129826 {
id="cluster_129826";
isCluster="true";
label="InMemoryTableScan";
49751 [id="node_49751" labelType="html" label="MapPartitionsRDD [49751] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49752 [id="node_49752" labelType="html" label="MapPartitionsRDD [49752] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49753 [id="node_49753" labelType="html" label="MapPartitionsRDD [49753] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129823 {
id="cluster_129823";
isCluster="true";
label="WholeStageCodegen (6)";
49754 [id="node_49754" labelType="html" label="MapPartitionsRDD [49754] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129744 {
id="cluster_129744";
isCluster="true";
label="Union";
49755 [id="node_49755" labelType="html" label="UnionRDD [49755] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_129743 {
id="cluster_129743";
isCluster="true";
label="InMemoryTableScan";
49756 [id="node_49756" labelType="html" label="MapPartitionsRDD [49756] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49757 [id="node_49757" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#995658, null AS demandStream#995659, [] AS kpis#995693, true AS isNewlyCalculated#995661]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#995650, ), isnull(shardId#995650), coalesce(worklistShardItemId#995651L, 0), isnull(worklistShardItemId#995651L), coalesce(version#995652, 0), isnull(version#995652), coalesce(product#995653, ), isnull(product#995653), coalesce(plant#995654, ), isnull(plant#995654), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#995425, 0.0))), isnull(qty#... [49757] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130032 {
id="cluster_130032";
isCluster="true";
label="Exchange";
49853 [id="node_49853" labelType="html" label="ShuffledRowRDD [49853] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130027 {
id="cluster_130027";
isCluster="true";
label="WholeStageCodegen (6)";
49854 [id="node_49854" labelType="html" label="MapPartitionsRDD [49854] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130026 {
id="cluster_130026";
isCluster="true";
label="SortAggregate";
49855 [id="node_49855" labelType="html" label="MapPartitionsRDD [49855] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130025 {
id="cluster_130025";
isCluster="true";
label="InMemoryTableScan";
49856 [id="node_49856" labelType="html" label="MapPartitionsRDD [49856] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49857 [id="node_49857" labelType="html" label="SortAggregate(key=[demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195], functions=[first(kpis#998223, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#998214, demandChannel#998194, demandStream#998195, kpis#998356])\n+- *(6) Sort [demandChannel#998194 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#998214 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#998195 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195, 37), ENSURE_REQUIREMENTS, [plan_id=1629820]\n +- SortAggregate(key=[demandChannel#998194, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#998214)) AS qty#998214, worklistShardItemId#943632L, demandStream#998195], functions=[partial_first(kpis#998223, false)], output=[demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195, first#99843... [49857] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130192 {
id="cluster_130192";
isCluster="true";
label="InMemoryTableScan";
49895 [id="node_49895" labelType="html" label="MapPartitionsRDD [49895] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49896 [id="node_49896" labelType="html" label="MapPartitionsRDD [49896] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49897 [id="node_49897" labelType="html" label="MapPartitionsRDD [49897] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130188 {
id="cluster_130188";
isCluster="true";
label="WholeStageCodegen (1)";
49898 [id="node_49898" labelType="html" label="MapPartitionsRDD [49898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130196 {
id="cluster_130196";
isCluster="true";
label="InMemoryTableScan";
49899 [id="node_49899" labelType="html" label="MapPartitionsRDD [49899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49900 [id="node_49900" labelType="html" label="MapPartitionsRDD [49900] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49901 [id="node_49901" labelType="html" label="MapPartitionsRDD [49901] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130193 {
id="cluster_130193";
isCluster="true";
label="WholeStageCodegen (2)";
49902 [id="node_49902" labelType="html" label="MapPartitionsRDD [49902] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130187 {
id="cluster_130187";
isCluster="true";
label="Union";
49903 [id="node_49903" labelType="html" label="UnionRDD [49903] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130163 {
id="cluster_130163";
isCluster="true";
label="WholeStageCodegen (5)";
49904 [id="node_49904" labelType="html" label="MapPartitionsRDD [49904] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130162 {
id="cluster_130162";
isCluster="true";
label="InMemoryTableScan";
49905 [id="node_49905" labelType="html" label="MapPartitionsRDD [49905] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49906 [id="node_49906" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#999027, qty#943638, demandChannel#995658, demandStream#995659, kpis#995693]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#999124, worklistShardItemId#999125L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#995658, demandStream#995659, kpis#995693]\n : : +- *(1) Filter ((NOT isNewlyCalculated#995661 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#995658, demandStream#995659, isNewlyCalculated#995661, kpis#995693, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#995661, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#995658, demandStream#995659... [49906] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_130221 {
id="cluster_130221";
isCluster="true";
label="InMemoryTableScan";
49915 [id="node_49915" labelType="html" label="MapPartitionsRDD [49915] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49916 [id="node_49916" labelType="html" label="MapPartitionsRDD [49916] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49917 [id="node_49917" labelType="html" label="MapPartitionsRDD [49917] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
49719->49720;
49731->49732;
49735->49736;
49732->49737;
49736->49737;
49737->49738;
49738->49739;
49739->49740;
49747->49748;
49720->49749;
49748->49749;
49749->49750;
49740->49751;
49751->49752;
49752->49753;
49753->49754;
49750->49755;
49754->49755;
49755->49756;
49756->49757;
49853->49854;
49854->49855;
49855->49856;
49856->49857;
49757->49895;
49895->49896;
49896->49897;
49897->49898;
49857->49899;
49899->49900;
49900->49901;
49901->49902;
49898->49903;
49902->49903;
49903->49904;
49904->49905;
49905->49906;
49906->49915;
49915->49916;
49916->49917;
}
49718,49719
49730,49731
49734,49735
49746,49747
49852,49853
49740
49757
49857
49906
49731
49732
49735
49736
49737
49738
49739
49740
49747
49748
49749
49750
49751
49752
49753
49754
49755
49756
49757
49853
49854
49855
49856
49857
49895
49896
49897
49898
49899
49900
49901
49902
49903
49904
49905
49906
49915
49916
49917