digraph G { id="graph_104102"; subgraph graph_stage_104102 { id="graph_stage_104102"; isCluster="true"; label="Stage 104102"; subgraph cluster_130377 { id="cluster_130377"; isCluster="true"; label="Exchange"; 49983 [id="node_49983" labelType="html" label="ShuffledRowRDD [49983] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130374 { id="cluster_130374"; isCluster="true"; label="WholeStageCodegen (1)"; 49984 [id="node_49984" labelType="html" label="MapPartitionsRDD [49984] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130397 { id="cluster_130397"; isCluster="true"; label="Exchange"; 49995 [id="node_49995" labelType="html" label="ShuffledRowRDD [49995] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130394 { id="cluster_130394"; isCluster="true"; label="WholeStageCodegen (4)"; 49996 [id="node_49996" labelType="html" label="MapPartitionsRDD [49996] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130432 { id="cluster_130432"; isCluster="true"; label="Exchange"; 49999 [id="node_49999" labelType="html" label="ShuffledRowRDD [49999] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130429 { id="cluster_130429"; isCluster="true"; label="WholeStageCodegen (6)"; 50000 [id="node_50000" labelType="html" label="MapPartitionsRDD [50000] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130386 { id="cluster_130386"; isCluster="true"; label="WholeStageCodegen (7)"; 50001 [id="node_50001" labelType="html" label="ZippedPartitionsRDD2 [50001] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50002 [id="node_50002" labelType="html" label="MapPartitionsRDD [50002] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130385 { id="cluster_130385"; isCluster="true"; label="InMemoryTableScan"; 50003 [id="node_50003" labelType="html" label="MapPartitionsRDD [50003] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50004 [id="node_50004" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#1000981 AS qty#1000983, demandChannel#1000976, demandStream#1000977, cachedKpis#1000982 AS kpis#1000984]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#1000980L, cachedShardId#1000979], 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=1630480]\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=1630476]\n : +- ... [50004] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130383 { id="cluster_130383"; isCluster="true"; label="Exchange"; 50011 [id="node_50011" labelType="html" label="ShuffledRowRDD [50011] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130380 { id="cluster_130380"; isCluster="true"; label="WholeStageCodegen (4)"; 50012 [id="node_50012" labelType="html" label="MapPartitionsRDD [50012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130366 { id="cluster_130366"; isCluster="true"; label="WholeStageCodegen (5)"; 50013 [id="node_50013" labelType="html" label="ZippedPartitionsRDD2 [50013] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50014 [id="node_50014" labelType="html" label="MapPartitionsRDD [50014] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130447 { id="cluster_130447"; isCluster="true"; label="InMemoryTableScan"; 50015 [id="node_50015" labelType="html" label="MapPartitionsRDD [50015] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50016 [id="node_50016" labelType="html" label="MapPartitionsRDD [50016] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50017 [id="node_50017" labelType="html" label="MapPartitionsRDD [50017] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130444 { id="cluster_130444"; isCluster="true"; label="WholeStageCodegen (6)"; 50018 [id="node_50018" labelType="html" label="MapPartitionsRDD [50018] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130365 { id="cluster_130365"; isCluster="true"; label="Union"; 50019 [id="node_50019" labelType="html" label="UnionRDD [50019] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130364 { id="cluster_130364"; isCluster="true"; label="InMemoryTableScan"; 50020 [id="node_50020" labelType="html" label="MapPartitionsRDD [50020] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50021 [id="node_50021" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#1001216, null AS demandStream#1001217, [] AS kpis#1001251, true AS isNewlyCalculated#1001219]\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#1001208, ), isnull(shardId#1001208), coalesce(worklistShardItemId#1001209L, 0), isnull(worklistShardItemId#1001209L), coalesce(version#1001210, 0), isnull(version#1001210), coalesce(product#1001211, ), isnull(product#1001211), coalesce(plant#1001212, ), isnull(plant#1001212), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1000983, 0.0)... [50021] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130575 { id="cluster_130575"; isCluster="true"; label="Exchange"; 50066 [id="node_50066" labelType="html" label="ShuffledRowRDD [50066] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130574 { id="cluster_130574"; isCluster="true"; label="ObjectHashAggregate"; 50067 [id="node_50067" labelType="html" label="MapPartitionsRDD [50067] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130586 { id="cluster_130586"; isCluster="true"; label="InMemoryTableScan"; 50068 [id="node_50068" labelType="html" label="MapPartitionsRDD [50068] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50069 [id="node_50069" labelType="html" label="MapPartitionsRDD [50069] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50070 [id="node_50070" labelType="html" label="MapPartitionsRDD [50070] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130582 { id="cluster_130582"; isCluster="true"; label="WholeStageCodegen (12)"; 50071 [id="node_50071" labelType="html" label="MapPartitionsRDD [50071] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130573 { id="cluster_130573"; isCluster="true"; label="Union"; 50072 [id="node_50072" labelType="html" label="UnionRDD [50072] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130572 { id="cluster_130572"; isCluster="true"; label="Exchange"; 50073 [id="node_50073" labelType="html" label="MapPartitionsRDD [50073] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49983->49984; 49995->49996; 49999->50000; 49996->50001; 50000->50001; 50001->50002; 50002->50003; 50003->50004; 50011->50012; 49984->50013; 50012->50013; 50013->50014; 50004->50015; 50015->50016; 50016->50017; 50017->50018; 50014->50019; 50018->50019; 50019->50020; 50020->50021; 50066->50067; 50021->50068; 50068->50069; 50069->50070; 50070->50071; 50067->50072; 50071->50072; 50072->50073; }