digraph G { id="graph_95925"; subgraph graph_stage_95925 { id="graph_stage_95925"; isCluster="true"; label="Stage 95925"; subgraph cluster_113596 { id="cluster_113596"; isCluster="true"; label="Exchange"; 43660 [id="node_43660" labelType="html" label="ShuffledRowRDD [43660] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113593 { id="cluster_113593"; isCluster="true"; label="WholeStageCodegen (1)"; 43661 [id="node_43661" labelType="html" label="MapPartitionsRDD [43661] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113616 { id="cluster_113616"; isCluster="true"; label="Exchange"; 43672 [id="node_43672" labelType="html" label="ShuffledRowRDD [43672] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113613 { id="cluster_113613"; isCluster="true"; label="WholeStageCodegen (4)"; 43673 [id="node_43673" labelType="html" label="MapPartitionsRDD [43673] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113651 { id="cluster_113651"; isCluster="true"; label="Exchange"; 43676 [id="node_43676" labelType="html" label="ShuffledRowRDD [43676] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113648 { id="cluster_113648"; isCluster="true"; label="WholeStageCodegen (6)"; 43677 [id="node_43677" labelType="html" label="MapPartitionsRDD [43677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113605 { id="cluster_113605"; isCluster="true"; label="WholeStageCodegen (7)"; 43678 [id="node_43678" labelType="html" label="ZippedPartitionsRDD2 [43678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43679 [id="node_43679" labelType="html" label="MapPartitionsRDD [43679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113604 { id="cluster_113604"; isCluster="true"; label="InMemoryTableScan"; 43680 [id="node_43680" labelType="html" label="MapPartitionsRDD [43680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43681 [id="node_43681" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#876907 AS qty#876909, demandChannel#876902, demandStream#876903, cachedKpis#876908 AS kpis#876910]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#876906L, cachedShardId#876905], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1386312]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1386308]\n : +- *(2) Has... [43681] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113602 { id="cluster_113602"; isCluster="true"; label="Exchange"; 43688 [id="node_43688" labelType="html" label="ShuffledRowRDD [43688] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113599 { id="cluster_113599"; isCluster="true"; label="WholeStageCodegen (4)"; 43689 [id="node_43689" labelType="html" label="MapPartitionsRDD [43689] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113585 { id="cluster_113585"; isCluster="true"; label="WholeStageCodegen (5)"; 43690 [id="node_43690" labelType="html" label="ZippedPartitionsRDD2 [43690] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43691 [id="node_43691" labelType="html" label="MapPartitionsRDD [43691] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113666 { id="cluster_113666"; isCluster="true"; label="InMemoryTableScan"; 43692 [id="node_43692" labelType="html" label="MapPartitionsRDD [43692] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43693 [id="node_43693" labelType="html" label="MapPartitionsRDD [43693] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43694 [id="node_43694" labelType="html" label="MapPartitionsRDD [43694] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113663 { id="cluster_113663"; isCluster="true"; label="WholeStageCodegen (6)"; 43695 [id="node_43695" labelType="html" label="MapPartitionsRDD [43695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113584 { id="cluster_113584"; isCluster="true"; label="Union"; 43696 [id="node_43696" labelType="html" label="UnionRDD [43696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113583 { id="cluster_113583"; isCluster="true"; label="InMemoryTableScan"; 43697 [id="node_43697" labelType="html" label="MapPartitionsRDD [43697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43698 [id="node_43698" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#877142, null AS demandStream#877143, [] AS kpis#877177, true AS isNewlyCalculated#877145]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#877134, ), isnull(shardId#877134), coalesce(worklistShardItemId#877135L, 0), isnull(worklistShardItemId#877135L), coalesce(version#877136, 0), isnull(version#877136), coalesce(product#877137, ), isnull(product#877137), coalesce(plant#877138, ), isnull(plant#877138), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#876909, 0.0))), isnull(qty#... [43698] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113887 { id="cluster_113887"; isCluster="true"; label="InMemoryTableScan"; 43764 [id="node_43764" labelType="html" label="MapPartitionsRDD [43764] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43765 [id="node_43765" labelType="html" label="MapPartitionsRDD [43765] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43766 [id="node_43766" labelType="html" label="MapPartitionsRDD [43766] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113882 { id="cluster_113882"; isCluster="true"; label="WholeStageCodegen (3)"; 43767 [id="node_43767" labelType="html" label="MapPartitionsRDD [43767] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113881 { id="cluster_113881"; isCluster="true"; label="Exchange"; 43768 [id="node_43768" labelType="html" label="MapPartitionsRDD [43768] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43660->43661; 43672->43673; 43676->43677; 43673->43678; 43677->43678; 43678->43679; 43679->43680; 43680->43681; 43688->43689; 43661->43690; 43689->43690; 43690->43691; 43681->43692; 43692->43693; 43693->43694; 43694->43695; 43691->43696; 43695->43696; 43696->43697; 43697->43698; 43698->43764; 43764->43765; 43765->43766; 43766->43767; 43767->43768; }