digraph G { id="graph_102215"; subgraph graph_stage_102215 { id="graph_stage_102215"; isCluster="true"; label="Stage 102215"; subgraph cluster_127270 { id="cluster_127270"; isCluster="true"; label="Exchange"; 48661 [id="node_48661" labelType="html" label="ShuffledRowRDD [48661] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127267 { id="cluster_127267"; isCluster="true"; label="WholeStageCodegen (1)"; 48662 [id="node_48662" labelType="html" label="MapPartitionsRDD [48662] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127290 { id="cluster_127290"; isCluster="true"; label="Exchange"; 48673 [id="node_48673" labelType="html" label="ShuffledRowRDD [48673] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127287 { id="cluster_127287"; isCluster="true"; label="WholeStageCodegen (4)"; 48674 [id="node_48674" labelType="html" label="MapPartitionsRDD [48674] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127325 { id="cluster_127325"; isCluster="true"; label="Exchange"; 48677 [id="node_48677" labelType="html" label="ShuffledRowRDD [48677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127322 { id="cluster_127322"; isCluster="true"; label="WholeStageCodegen (6)"; 48678 [id="node_48678" labelType="html" label="MapPartitionsRDD [48678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127279 { id="cluster_127279"; isCluster="true"; label="WholeStageCodegen (7)"; 48679 [id="node_48679" labelType="html" label="ZippedPartitionsRDD2 [48679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48680 [id="node_48680" labelType="html" label="MapPartitionsRDD [48680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127278 { id="cluster_127278"; isCluster="true"; label="InMemoryTableScan"; 48681 [id="node_48681" labelType="html" label="MapPartitionsRDD [48681] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48682 [id="node_48682" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#973191 AS qty#973193, demandChannel#973186, demandStream#973187, cachedKpis#973192 AS kpis#973194]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#973190L, cachedShardId#973189], 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=1622545]\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=1622541]\n : +- *(2) Has... [48682] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127276 { id="cluster_127276"; isCluster="true"; label="Exchange"; 48689 [id="node_48689" labelType="html" label="ShuffledRowRDD [48689] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127273 { id="cluster_127273"; isCluster="true"; label="WholeStageCodegen (4)"; 48690 [id="node_48690" labelType="html" label="MapPartitionsRDD [48690] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127260 { id="cluster_127260"; isCluster="true"; label="WholeStageCodegen (5)"; 48691 [id="node_48691" labelType="html" label="ZippedPartitionsRDD2 [48691] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48692 [id="node_48692" labelType="html" label="MapPartitionsRDD [48692] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127340 { id="cluster_127340"; isCluster="true"; label="InMemoryTableScan"; 48693 [id="node_48693" labelType="html" label="MapPartitionsRDD [48693] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48694 [id="node_48694" labelType="html" label="MapPartitionsRDD [48694] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48695 [id="node_48695" labelType="html" label="MapPartitionsRDD [48695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127337 { id="cluster_127337"; isCluster="true"; label="WholeStageCodegen (6)"; 48696 [id="node_48696" labelType="html" label="MapPartitionsRDD [48696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127258 { id="cluster_127258"; isCluster="true"; label="Union"; 48697 [id="node_48697" labelType="html" label="UnionRDD [48697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127257 { id="cluster_127257"; isCluster="true"; label="InMemoryTableScan"; 48698 [id="node_48698" labelType="html" label="MapPartitionsRDD [48698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48699 [id="node_48699" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#973426, null AS demandStream#973427, [] AS kpis#973461, true AS isNewlyCalculated#973429]\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#973418, ), isnull(shardId#973418), coalesce(worklistShardItemId#973419L, 0), isnull(worklistShardItemId#973419L), coalesce(version#973420, 0), isnull(version#973420), coalesce(product#973421, ), isnull(product#973421), coalesce(plant#973422, ), isnull(plant#973422), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#973193, 0.0))), isnull(qty#... [48699] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127691 { id="cluster_127691"; isCluster="true"; label="InMemoryTableScan"; 48830 [id="node_48830" labelType="html" label="MapPartitionsRDD [48830] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48831 [id="node_48831" labelType="html" label="MapPartitionsRDD [48831] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48832 [id="node_48832" labelType="html" label="MapPartitionsRDD [48832] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127687 { id="cluster_127687"; isCluster="true"; label="WholeStageCodegen (3)"; 48833 [id="node_48833" labelType="html" label="MapPartitionsRDD [48833] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127686 { id="cluster_127686"; isCluster="true"; label="Exchange"; 48834 [id="node_48834" labelType="html" label="MapPartitionsRDD [48834] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 48661->48662; 48673->48674; 48677->48678; 48674->48679; 48678->48679; 48679->48680; 48680->48681; 48681->48682; 48689->48690; 48662->48691; 48690->48691; 48691->48692; 48682->48693; 48693->48694; 48694->48695; 48695->48696; 48692->48697; 48696->48697; 48697->48698; 48698->48699; 48699->48830; 48830->48831; 48831->48832; 48832->48833; 48833->48834; }