digraph G { id="graph_92885"; subgraph graph_stage_92885 { id="graph_stage_92885"; isCluster="true"; label="Stage 92885"; subgraph cluster_111099 { id="cluster_111099"; isCluster="true"; label="Exchange"; 42598 [id="node_42598" labelType="html" label="ShuffledRowRDD [42598] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111096 { id="cluster_111096"; isCluster="true"; label="WholeStageCodegen (1)"; 42599 [id="node_42599" labelType="html" label="MapPartitionsRDD [42599] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111119 { id="cluster_111119"; isCluster="true"; label="Exchange"; 42610 [id="node_42610" labelType="html" label="ShuffledRowRDD [42610] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111116 { id="cluster_111116"; isCluster="true"; label="WholeStageCodegen (4)"; 42611 [id="node_42611" labelType="html" label="MapPartitionsRDD [42611] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111154 { id="cluster_111154"; isCluster="true"; label="Exchange"; 42614 [id="node_42614" labelType="html" label="ShuffledRowRDD [42614] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111151 { id="cluster_111151"; isCluster="true"; label="WholeStageCodegen (6)"; 42615 [id="node_42615" labelType="html" label="MapPartitionsRDD [42615] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111108 { id="cluster_111108"; isCluster="true"; label="WholeStageCodegen (7)"; 42616 [id="node_42616" labelType="html" label="ZippedPartitionsRDD2 [42616] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42617 [id="node_42617" labelType="html" label="MapPartitionsRDD [42617] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111107 { id="cluster_111107"; isCluster="true"; label="InMemoryTableScan"; 42618 [id="node_42618" labelType="html" label="MapPartitionsRDD [42618] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42619 [id="node_42619" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#854653 AS qty#854655, demandChannel#854648, demandStream#854649, cachedKpis#854654 AS kpis#854656]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#854652L, cachedShardId#854651], 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=1380012]\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=1380008]\n : +- *(2) Has... [42619] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111105 { id="cluster_111105"; isCluster="true"; label="Exchange"; 42626 [id="node_42626" labelType="html" label="ShuffledRowRDD [42626] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111102 { id="cluster_111102"; isCluster="true"; label="WholeStageCodegen (4)"; 42627 [id="node_42627" labelType="html" label="MapPartitionsRDD [42627] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111088 { id="cluster_111088"; isCluster="true"; label="WholeStageCodegen (5)"; 42628 [id="node_42628" labelType="html" label="ZippedPartitionsRDD2 [42628] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42629 [id="node_42629" labelType="html" label="MapPartitionsRDD [42629] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111169 { id="cluster_111169"; isCluster="true"; label="InMemoryTableScan"; 42630 [id="node_42630" labelType="html" label="MapPartitionsRDD [42630] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42631 [id="node_42631" labelType="html" label="MapPartitionsRDD [42631] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42632 [id="node_42632" labelType="html" label="MapPartitionsRDD [42632] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111166 { id="cluster_111166"; isCluster="true"; label="WholeStageCodegen (6)"; 42633 [id="node_42633" labelType="html" label="MapPartitionsRDD [42633] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111087 { id="cluster_111087"; isCluster="true"; label="Union"; 42634 [id="node_42634" labelType="html" label="UnionRDD [42634] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111086 { id="cluster_111086"; isCluster="true"; label="InMemoryTableScan"; 42635 [id="node_42635" labelType="html" label="MapPartitionsRDD [42635] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42636 [id="node_42636" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#854888, null AS demandStream#854889, [] AS kpis#854923, true AS isNewlyCalculated#854891]\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#854880, ), isnull(shardId#854880), coalesce(worklistShardItemId#854881L, 0), isnull(worklistShardItemId#854881L), coalesce(version#854882, 0), isnull(version#854882), coalesce(product#854883, ), isnull(product#854883), coalesce(plant#854884, ), isnull(plant#854884), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#854655, 0.0))), isnull(qty#... [42636] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111519 { id="cluster_111519"; isCluster="true"; label="InMemoryTableScan"; 42766 [id="node_42766" labelType="html" label="MapPartitionsRDD [42766] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42767 [id="node_42767" labelType="html" label="MapPartitionsRDD [42767] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42768 [id="node_42768" labelType="html" label="MapPartitionsRDD [42768] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111515 { id="cluster_111515"; isCluster="true"; label="WholeStageCodegen (3)"; 42769 [id="node_42769" labelType="html" label="MapPartitionsRDD [42769] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111514 { id="cluster_111514"; isCluster="true"; label="Exchange"; 42770 [id="node_42770" labelType="html" label="MapPartitionsRDD [42770] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42598->42599; 42610->42611; 42614->42615; 42611->42616; 42615->42616; 42616->42617; 42617->42618; 42618->42619; 42626->42627; 42599->42628; 42627->42628; 42628->42629; 42619->42630; 42630->42631; 42631->42632; 42632->42633; 42629->42634; 42633->42634; 42634->42635; 42635->42636; 42636->42766; 42766->42767; 42767->42768; 42768->42769; 42769->42770; }