digraph G { id="graph_98913"; subgraph graph_stage_98913 { id="graph_stage_98913"; isCluster="true"; label="Stage 98913"; 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_116413 { id="cluster_116413"; isCluster="true"; label="Exchange"; 44872 [id="node_44872" labelType="html" label="ShuffledRowRDD [44872] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116408 { id="cluster_116408"; isCluster="true"; label="WholeStageCodegen (6)"; 44873 [id="node_44873" labelType="html" label="MapPartitionsRDD [44873] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116407 { id="cluster_116407"; isCluster="true"; label="SortAggregate"; 44874 [id="node_44874" labelType="html" label="MapPartitionsRDD [44874] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116406 { id="cluster_116406"; isCluster="true"; label="InMemoryTableScan"; 44875 [id="node_44875" labelType="html" label="MapPartitionsRDD [44875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44876 [id="node_44876" labelType="html" label="SortAggregate(key=[demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210], functions=[first(kpis#902238, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#902229, demandChannel#902209, demandStream#902210, kpis#902371])\n+- *(6) Sort [demandChannel#902209 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#902229 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#902210 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210, 37), ENSURE_REQUIREMENTS, [plan_id=1393658]\n +- SortAggregate(key=[demandChannel#902209, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#902229)) AS qty#902229, worklistShardItemId#815741L, demandStream#902210], functions=[partial_first(kpis#902238, false)], output=[demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210, first#90244... [44876] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116573 { id="cluster_116573"; isCluster="true"; label="InMemoryTableScan"; 44914 [id="node_44914" labelType="html" label="MapPartitionsRDD [44914] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44915 [id="node_44915" labelType="html" label="MapPartitionsRDD [44915] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44916 [id="node_44916" labelType="html" label="MapPartitionsRDD [44916] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116569 { id="cluster_116569"; isCluster="true"; label="WholeStageCodegen (1)"; 44917 [id="node_44917" labelType="html" label="MapPartitionsRDD [44917] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116577 { id="cluster_116577"; isCluster="true"; label="InMemoryTableScan"; 44918 [id="node_44918" labelType="html" label="MapPartitionsRDD [44918] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44919 [id="node_44919" labelType="html" label="MapPartitionsRDD [44919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44920 [id="node_44920" labelType="html" label="MapPartitionsRDD [44920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116574 { id="cluster_116574"; isCluster="true"; label="WholeStageCodegen (2)"; 44921 [id="node_44921" labelType="html" label="MapPartitionsRDD [44921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116568 { id="cluster_116568"; isCluster="true"; label="Union"; 44922 [id="node_44922" labelType="html" label="UnionRDD [44922] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116544 { id="cluster_116544"; isCluster="true"; label="WholeStageCodegen (5)"; 44923 [id="node_44923" labelType="html" label="MapPartitionsRDD [44923] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116543 { id="cluster_116543"; isCluster="true"; label="InMemoryTableScan"; 44924 [id="node_44924" labelType="html" label="MapPartitionsRDD [44924] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44925 [id="node_44925" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#903042, qty#815747, demandChannel#899673, demandStream#899674, kpis#899708]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#903139, worklistShardItemId#903140L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#899673, demandStream#899674, kpis#899708]\n : : +- *(1) Filter ((NOT isNewlyCalculated#899676 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#899673, demandStream#899674, isNewlyCalculated#899676, kpis#899708, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#899676, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#899673, demandStream#899674... [44925] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44926 [id="node_44926" labelType="html" label="MapPartitionsRDD [44926] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44927 [id="node_44927" labelType="html" label="MapPartitionsRDD [44927] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44928 [id="node_44928" labelType="html" label="MapPartitionsRDD [44928] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116542 { id="cluster_116542"; isCluster="true"; label="CollectLimit"; 44929 [id="node_44929" labelType="html" label="MapPartitionsRDD [44929] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44930 [id="node_44930" labelType="html" label="MapPartitionsRDD [44930] [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; 44872->44873; 44873->44874; 44874->44875; 44875->44876; 44776->44914; 44914->44915; 44915->44916; 44916->44917; 44876->44918; 44918->44919; 44919->44920; 44920->44921; 44917->44922; 44921->44922; 44922->44923; 44923->44924; 44924->44925; 44925->44926; 44926->44927; 44927->44928; 44928->44929; 44929->44930; }