digraph G { id="graph_95897"; subgraph graph_stage_95897 { id="graph_stage_95897"; isCluster="true"; label="Stage 95897"; 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_113794 { id="cluster_113794"; isCluster="true"; label="Exchange"; 43743 [id="node_43743" labelType="html" label="ShuffledRowRDD [43743] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113793 { id="cluster_113793"; isCluster="true"; label="ObjectHashAggregate"; 43744 [id="node_43744" labelType="html" label="MapPartitionsRDD [43744] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113805 { id="cluster_113805"; isCluster="true"; label="InMemoryTableScan"; 43745 [id="node_43745" labelType="html" label="MapPartitionsRDD [43745] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43746 [id="node_43746" labelType="html" label="MapPartitionsRDD [43746] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43747 [id="node_43747" labelType="html" label="MapPartitionsRDD [43747] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113801 { id="cluster_113801"; isCluster="true"; label="WholeStageCodegen (12)"; 43748 [id="node_43748" labelType="html" label="MapPartitionsRDD [43748] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113792 { id="cluster_113792"; isCluster="true"; label="Union"; 43749 [id="node_43749" labelType="html" label="UnionRDD [43749] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113791 { id="cluster_113791"; isCluster="true"; label="Exchange"; 43750 [id="node_43750" labelType="html" label="MapPartitionsRDD [43750] [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; 43743->43744; 43698->43745; 43745->43746; 43746->43747; 43747->43748; 43744->43749; 43748->43749; 43749->43750; }