digraph G { id="graph_103767"; subgraph graph_stage_103767 { id="graph_stage_103767"; isCluster="true"; label="Stage 103767"; 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_130176 { id="cluster_130176"; isCluster="true"; label="InMemoryTableScan"; 49887 [id="node_49887" labelType="html" label="MapPartitionsRDD [49887] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49888 [id="node_49888" labelType="html" label="MapPartitionsRDD [49888] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49889 [id="node_49889" labelType="html" label="MapPartitionsRDD [49889] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130172 { id="cluster_130172"; isCluster="true"; label="WholeStageCodegen (3)"; 49890 [id="node_49890" labelType="html" label="MapPartitionsRDD [49890] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130171 { id="cluster_130171"; isCluster="true"; label="Exchange"; 49891 [id="node_49891" labelType="html" label="MapPartitionsRDD [49891] [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; 49757->49887; 49887->49888; 49888->49889; 49889->49890; 49890->49891; }