digraph G { id="graph_100600"; subgraph graph_stage_100600 { id="graph_stage_100600"; isCluster="true"; label="Stage 100600"; subgraph cluster_121080 { id="cluster_121080"; isCluster="true"; label="Exchange"; 46645 [id="node_46645" labelType="html" label="ShuffledRowRDD [46645] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121077 { id="cluster_121077"; isCluster="true"; label="WholeStageCodegen (1)"; 46646 [id="node_46646" labelType="html" label="MapPartitionsRDD [46646] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121100 { id="cluster_121100"; isCluster="true"; label="Exchange"; 46657 [id="node_46657" labelType="html" label="ShuffledRowRDD [46657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121097 { id="cluster_121097"; isCluster="true"; label="WholeStageCodegen (4)"; 46658 [id="node_46658" labelType="html" label="MapPartitionsRDD [46658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121129 { id="cluster_121129"; isCluster="true"; label="Exchange"; 46661 [id="node_46661" labelType="html" label="ShuffledRowRDD [46661] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121126 { id="cluster_121126"; isCluster="true"; label="WholeStageCodegen (6)"; 46662 [id="node_46662" labelType="html" label="MapPartitionsRDD [46662] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121089 { id="cluster_121089"; isCluster="true"; label="WholeStageCodegen (7)"; 46663 [id="node_46663" labelType="html" label="ZippedPartitionsRDD2 [46663] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46664 [id="node_46664" labelType="html" label="MapPartitionsRDD [46664] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121088 { id="cluster_121088"; isCluster="true"; label="InMemoryTableScan"; 46665 [id="node_46665" labelType="html" label="MapPartitionsRDD [46665] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46666 [id="node_46666" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#938355 AS qty#938357, demandChannel#938350, demandStream#938351, cachedKpis#938356 AS kpis#938358]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#938354L, cachedShardId#938353], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1454068]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1454064]\n : +- *(2) Has... [46666] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121086 { id="cluster_121086"; isCluster="true"; label="Exchange"; 46673 [id="node_46673" labelType="html" label="ShuffledRowRDD [46673] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121083 { id="cluster_121083"; isCluster="true"; label="WholeStageCodegen (4)"; 46674 [id="node_46674" labelType="html" label="MapPartitionsRDD [46674] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121069 { id="cluster_121069"; isCluster="true"; label="WholeStageCodegen (5)"; 46675 [id="node_46675" labelType="html" label="ZippedPartitionsRDD2 [46675] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46676 [id="node_46676" labelType="html" label="MapPartitionsRDD [46676] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121144 { id="cluster_121144"; isCluster="true"; label="InMemoryTableScan"; 46677 [id="node_46677" labelType="html" label="MapPartitionsRDD [46677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46678 [id="node_46678" labelType="html" label="MapPartitionsRDD [46678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46679 [id="node_46679" labelType="html" label="MapPartitionsRDD [46679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121141 { id="cluster_121141"; isCluster="true"; label="WholeStageCodegen (6)"; 46680 [id="node_46680" labelType="html" label="MapPartitionsRDD [46680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121068 { id="cluster_121068"; isCluster="true"; label="Union"; 46681 [id="node_46681" labelType="html" label="UnionRDD [46681] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121067 { id="cluster_121067"; isCluster="true"; label="InMemoryTableScan"; 46682 [id="node_46682" labelType="html" label="MapPartitionsRDD [46682] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46683 [id="node_46683" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#938590, null AS demandStream#938591, [] AS kpis#938625, true AS isNewlyCalculated#938593]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#938582, ), isnull(shardId#938582), coalesce(worklistShardItemId#938583L, 0), isnull(worklistShardItemId#938583L), coalesce(version#938584, 0), isnull(version#938584), coalesce(product#938585, ), isnull(product#938585), coalesce(plant#938586, ), isnull(plant#938586), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#938357, 0.0))), isnull(qty#... [46683] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121500 { id="cluster_121500"; isCluster="true"; label="InMemoryTableScan"; 46813 [id="node_46813" labelType="html" label="MapPartitionsRDD [46813] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46814 [id="node_46814" labelType="html" label="MapPartitionsRDD [46814] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46815 [id="node_46815" labelType="html" label="MapPartitionsRDD [46815] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121496 { id="cluster_121496"; isCluster="true"; label="WholeStageCodegen (3)"; 46816 [id="node_46816" labelType="html" label="MapPartitionsRDD [46816] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121495 { id="cluster_121495"; isCluster="true"; label="Exchange"; 46817 [id="node_46817" labelType="html" label="MapPartitionsRDD [46817] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46645->46646; 46657->46658; 46661->46662; 46658->46663; 46662->46663; 46663->46664; 46664->46665; 46665->46666; 46673->46674; 46646->46675; 46674->46675; 46675->46676; 46666->46677; 46677->46678; 46678->46679; 46679->46680; 46676->46681; 46680->46681; 46681->46682; 46682->46683; 46683->46813; 46813->46814; 46814->46815; 46815->46816; 46816->46817; }