digraph G { id="graph_103839"; subgraph graph_stage_103839 { id="graph_stage_103839"; isCluster="true"; label="Stage 103839"; 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}"]; 49907 [id="node_49907" labelType="html" label="MapPartitionsRDD [49907] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49908 [id="node_49908" labelType="html" label="MapPartitionsRDD [49908] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49909 [id="node_49909" labelType="html" label="MapPartitionsRDD [49909] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130161 { id="cluster_130161"; isCluster="true"; label="CollectLimit"; 49910 [id="node_49910" labelType="html" label="MapPartitionsRDD [49910] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49911 [id="node_49911" labelType="html" label="MapPartitionsRDD [49911] [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->49907; 49907->49908; 49908->49909; 49909->49910; 49910->49911; }