digraph G { id="graph_104533"; subgraph graph_stage_104533 { id="graph_stage_104533"; isCluster="true"; label="Stage 104533"; 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_130797 { id="cluster_130797"; isCluster="true"; label="InMemoryTableScan"; 50151 [id="node_50151" labelType="html" label="MapPartitionsRDD [50151] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50152 [id="node_50152" labelType="html" label="MapPartitionsRDD [50152] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50153 [id="node_50153" labelType="html" label="MapPartitionsRDD [50153] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130793 { id="cluster_130793"; isCluster="true"; label="WholeStageCodegen (3)"; 50154 [id="node_50154" labelType="html" label="MapPartitionsRDD [50154] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130792 { id="cluster_130792"; isCluster="true"; label="Exchange"; 50155 [id="node_50155" labelType="html" label="MapPartitionsRDD [50155] [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; 50021->50151; 50151->50152; 50152->50153; 50153->50154; 50154->50155; }