digraph G { id="graph_93101"; subgraph graph_stage_93101 { id="graph_stage_93101"; isCluster="true"; label="Stage 93101"; 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_111375 { id="cluster_111375"; isCluster="true"; label="Exchange"; 42732 [id="node_42732" labelType="html" label="ShuffledRowRDD [42732] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111370 { id="cluster_111370"; isCluster="true"; label="WholeStageCodegen (6)"; 42733 [id="node_42733" labelType="html" label="MapPartitionsRDD [42733] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111369 { id="cluster_111369"; isCluster="true"; label="SortAggregate"; 42734 [id="node_42734" labelType="html" label="MapPartitionsRDD [42734] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111368 { id="cluster_111368"; isCluster="true"; label="InMemoryTableScan"; 42735 [id="node_42735" labelType="html" label="MapPartitionsRDD [42735] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42736 [id="node_42736" labelType="html" label="SortAggregate(key=[demandChannel#857424, shardId#815740, qty#857444, worklistShardItemId#815741L, demandStream#857425], functions=[first(kpis#857453, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#857444, demandChannel#857424, demandStream#857425, kpis#857586])\n+- *(6) Sort [demandChannel#857424 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#857444 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#857425 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#857424, shardId#815740, qty#857444, worklistShardItemId#815741L, demandStream#857425, 37), ENSURE_REQUIREMENTS, [plan_id=1380942]\n +- SortAggregate(key=[demandChannel#857424, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#857444)) AS qty#857444, worklistShardItemId#815741L, demandStream#857425], functions=[partial_first(kpis#857453, false)], output=[demandChannel#857424, shardId#815740, qty#857444, worklistShardItemId#815741L, demandStream#857425, first#85766... [42736] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111535 { id="cluster_111535"; isCluster="true"; label="InMemoryTableScan"; 42774 [id="node_42774" labelType="html" label="MapPartitionsRDD [42774] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42775 [id="node_42775" labelType="html" label="MapPartitionsRDD [42775] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42776 [id="node_42776" labelType="html" label="MapPartitionsRDD [42776] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111531 { id="cluster_111531"; isCluster="true"; label="WholeStageCodegen (1)"; 42777 [id="node_42777" labelType="html" label="MapPartitionsRDD [42777] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111539 { id="cluster_111539"; isCluster="true"; label="InMemoryTableScan"; 42778 [id="node_42778" labelType="html" label="MapPartitionsRDD [42778] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42779 [id="node_42779" labelType="html" label="MapPartitionsRDD [42779] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42780 [id="node_42780" labelType="html" label="MapPartitionsRDD [42780] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111536 { id="cluster_111536"; isCluster="true"; label="WholeStageCodegen (2)"; 42781 [id="node_42781" labelType="html" label="MapPartitionsRDD [42781] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111530 { id="cluster_111530"; isCluster="true"; label="Union"; 42782 [id="node_42782" labelType="html" label="UnionRDD [42782] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111506 { id="cluster_111506"; isCluster="true"; label="WholeStageCodegen (5)"; 42783 [id="node_42783" labelType="html" label="MapPartitionsRDD [42783] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111505 { id="cluster_111505"; isCluster="true"; label="InMemoryTableScan"; 42784 [id="node_42784" labelType="html" label="MapPartitionsRDD [42784] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42785 [id="node_42785" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#858257, qty#815747, demandChannel#854888, demandStream#854889, kpis#854923]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#858354, worklistShardItemId#858355L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#854888, demandStream#854889, kpis#854923]\n : : +- *(1) Filter ((NOT isNewlyCalculated#854891 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#854888, demandStream#854889, isNewlyCalculated#854891, kpis#854923, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#854891, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#854888, demandStream#854889... [42785] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111564 { id="cluster_111564"; isCluster="true"; label="InMemoryTableScan"; 42794 [id="node_42794" labelType="html" label="MapPartitionsRDD [42794] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42795 [id="node_42795" labelType="html" label="MapPartitionsRDD [42795] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42796 [id="node_42796" labelType="html" label="MapPartitionsRDD [42796] [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; 42732->42733; 42733->42734; 42734->42735; 42735->42736; 42636->42774; 42774->42775; 42775->42776; 42776->42777; 42736->42778; 42778->42779; 42779->42780; 42780->42781; 42777->42782; 42781->42782; 42782->42783; 42783->42784; 42784->42785; 42785->42794; 42794->42795; 42795->42796; }