digraph G { id="graph_103489"; subgraph graph_stage_103489 { id="graph_stage_103489"; isCluster="true"; label="Stage 103489"; 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_130047 { id="cluster_130047"; isCluster="true"; label="InMemoryTableScan"; 49823 [id="node_49823" labelType="html" label="MapPartitionsRDD [49823] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49824 [id="node_49824" labelType="html" label="MapPartitionsRDD [49824] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49825 [id="node_49825" labelType="html" label="MapPartitionsRDD [49825] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130042 { id="cluster_130042"; isCluster="true"; label="WholeStageCodegen (3)"; 49826 [id="node_49826" labelType="html" label="MapPartitionsRDD [49826] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130041 { id="cluster_130041"; isCluster="true"; label="Exchange"; 49827 [id="node_49827" labelType="html" label="MapPartitionsRDD [49827] [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->49823; 49823->49824; 49824->49825; 49825->49826; 49826->49827; }