digraph G { id="graph_98805"; subgraph graph_stage_98805 { id="graph_stage_98805"; isCluster="true"; label="Stage 98805"; subgraph cluster_116137 { id="cluster_116137"; isCluster="true"; label="Exchange"; 44738 [id="node_44738" labelType="html" label="ShuffledRowRDD [44738] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116134 { id="cluster_116134"; isCluster="true"; label="WholeStageCodegen (1)"; 44739 [id="node_44739" labelType="html" label="MapPartitionsRDD [44739] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116157 { id="cluster_116157"; isCluster="true"; label="Exchange"; 44750 [id="node_44750" labelType="html" label="ShuffledRowRDD [44750] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116154 { id="cluster_116154"; isCluster="true"; label="WholeStageCodegen (4)"; 44751 [id="node_44751" labelType="html" label="MapPartitionsRDD [44751] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116192 { id="cluster_116192"; isCluster="true"; label="Exchange"; 44754 [id="node_44754" labelType="html" label="ShuffledRowRDD [44754] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116189 { id="cluster_116189"; isCluster="true"; label="WholeStageCodegen (6)"; 44755 [id="node_44755" labelType="html" label="MapPartitionsRDD [44755] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116146 { id="cluster_116146"; isCluster="true"; label="WholeStageCodegen (7)"; 44756 [id="node_44756" labelType="html" label="ZippedPartitionsRDD2 [44756] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44757 [id="node_44757" labelType="html" label="MapPartitionsRDD [44757] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116145 { id="cluster_116145"; isCluster="true"; label="InMemoryTableScan"; 44758 [id="node_44758" labelType="html" label="MapPartitionsRDD [44758] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44759 [id="node_44759" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#899438 AS qty#899440, demandChannel#899433, demandStream#899434, cachedKpis#899439 AS kpis#899441]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#899437L, cachedShardId#899436], 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=1392728]\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=1392724]\n : +- *(2) Has... [44759] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116143 { id="cluster_116143"; isCluster="true"; label="Exchange"; 44766 [id="node_44766" labelType="html" label="ShuffledRowRDD [44766] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116140 { id="cluster_116140"; isCluster="true"; label="WholeStageCodegen (4)"; 44767 [id="node_44767" labelType="html" label="MapPartitionsRDD [44767] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116126 { id="cluster_116126"; isCluster="true"; label="WholeStageCodegen (5)"; 44768 [id="node_44768" labelType="html" label="ZippedPartitionsRDD2 [44768] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44769 [id="node_44769" labelType="html" label="MapPartitionsRDD [44769] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116207 { id="cluster_116207"; isCluster="true"; label="InMemoryTableScan"; 44770 [id="node_44770" labelType="html" label="MapPartitionsRDD [44770] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44771 [id="node_44771" labelType="html" label="MapPartitionsRDD [44771] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44772 [id="node_44772" labelType="html" label="MapPartitionsRDD [44772] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116204 { id="cluster_116204"; isCluster="true"; label="WholeStageCodegen (6)"; 44773 [id="node_44773" labelType="html" label="MapPartitionsRDD [44773] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116125 { id="cluster_116125"; isCluster="true"; label="Union"; 44774 [id="node_44774" labelType="html" label="UnionRDD [44774] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116124 { id="cluster_116124"; isCluster="true"; label="InMemoryTableScan"; 44775 [id="node_44775" labelType="html" label="MapPartitionsRDD [44775] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44776 [id="node_44776" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#899673, null AS demandStream#899674, [] AS kpis#899708, true AS isNewlyCalculated#899676]\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#899665, ), isnull(shardId#899665), coalesce(worklistShardItemId#899666L, 0), isnull(worklistShardItemId#899666L), coalesce(version#899667, 0), isnull(version#899667), coalesce(product#899668, ), isnull(product#899668), coalesce(plant#899669, ), isnull(plant#899669), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#899440, 0.0))), isnull(qty#... [44776] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116557 { id="cluster_116557"; isCluster="true"; label="InMemoryTableScan"; 44906 [id="node_44906" labelType="html" label="MapPartitionsRDD [44906] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44907 [id="node_44907" labelType="html" label="MapPartitionsRDD [44907] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44908 [id="node_44908" labelType="html" label="MapPartitionsRDD [44908] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116553 { id="cluster_116553"; isCluster="true"; label="WholeStageCodegen (3)"; 44909 [id="node_44909" labelType="html" label="MapPartitionsRDD [44909] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116552 { id="cluster_116552"; isCluster="true"; label="Exchange"; 44910 [id="node_44910" labelType="html" label="MapPartitionsRDD [44910] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44738->44739; 44750->44751; 44754->44755; 44751->44756; 44755->44756; 44756->44757; 44757->44758; 44758->44759; 44766->44767; 44739->44768; 44767->44768; 44768->44769; 44759->44770; 44770->44771; 44771->44772; 44772->44773; 44769->44774; 44773->44774; 44774->44775; 44775->44776; 44776->44906; 44906->44907; 44907->44908; 44908->44909; 44909->44910; }