digraph G { id="graph_95515"; subgraph graph_stage_95515 { id="graph_stage_95515"; isCluster="true"; label="Stage 95515"; subgraph cluster_112341 { id="cluster_112341"; isCluster="true"; label="Exchange"; 43126 [id="node_43126" labelType="html" label="ShuffledRowRDD [43126] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112338 { id="cluster_112338"; isCluster="true"; label="WholeStageCodegen (1)"; 43127 [id="node_43127" labelType="html" label="MapPartitionsRDD [43127] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112361 { id="cluster_112361"; isCluster="true"; label="Exchange"; 43138 [id="node_43138" labelType="html" label="ShuffledRowRDD [43138] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112358 { id="cluster_112358"; isCluster="true"; label="WholeStageCodegen (4)"; 43139 [id="node_43139" labelType="html" label="MapPartitionsRDD [43139] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112396 { id="cluster_112396"; isCluster="true"; label="Exchange"; 43142 [id="node_43142" labelType="html" label="ShuffledRowRDD [43142] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112393 { id="cluster_112393"; isCluster="true"; label="WholeStageCodegen (6)"; 43143 [id="node_43143" labelType="html" label="MapPartitionsRDD [43143] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112350 { id="cluster_112350"; isCluster="true"; label="WholeStageCodegen (7)"; 43144 [id="node_43144" labelType="html" label="ZippedPartitionsRDD2 [43144] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43145 [id="node_43145" labelType="html" label="MapPartitionsRDD [43145] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112349 { id="cluster_112349"; isCluster="true"; label="InMemoryTableScan"; 43146 [id="node_43146" labelType="html" label="MapPartitionsRDD [43146] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43147 [id="node_43147" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#865769 AS qty#865771, demandChannel#865764, demandStream#865765, cachedKpis#865770 AS kpis#865772]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#865768L, cachedShardId#865767], 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=1383136]\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=1383132]\n : +- *(2) Has... [43147] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112347 { id="cluster_112347"; isCluster="true"; label="Exchange"; 43154 [id="node_43154" labelType="html" label="ShuffledRowRDD [43154] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112344 { id="cluster_112344"; isCluster="true"; label="WholeStageCodegen (4)"; 43155 [id="node_43155" labelType="html" label="MapPartitionsRDD [43155] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112330 { id="cluster_112330"; isCluster="true"; label="WholeStageCodegen (5)"; 43156 [id="node_43156" labelType="html" label="ZippedPartitionsRDD2 [43156] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43157 [id="node_43157" labelType="html" label="MapPartitionsRDD [43157] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112411 { id="cluster_112411"; isCluster="true"; label="InMemoryTableScan"; 43158 [id="node_43158" labelType="html" label="MapPartitionsRDD [43158] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43159 [id="node_43159" labelType="html" label="MapPartitionsRDD [43159] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43160 [id="node_43160" labelType="html" label="MapPartitionsRDD [43160] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112408 { id="cluster_112408"; isCluster="true"; label="WholeStageCodegen (6)"; 43161 [id="node_43161" labelType="html" label="MapPartitionsRDD [43161] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112329 { id="cluster_112329"; isCluster="true"; label="Union"; 43162 [id="node_43162" labelType="html" label="UnionRDD [43162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112328 { id="cluster_112328"; isCluster="true"; label="InMemoryTableScan"; 43163 [id="node_43163" labelType="html" label="MapPartitionsRDD [43163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43164 [id="node_43164" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#866004, null AS demandStream#866005, [] AS kpis#866039, true AS isNewlyCalculated#866007]\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#865996, ), isnull(shardId#865996), coalesce(worklistShardItemId#865997L, 0), isnull(worklistShardItemId#865997L), coalesce(version#865998, 0), isnull(version#865998), coalesce(product#865999, ), isnull(product#865999), coalesce(plant#866000, ), isnull(plant#866000), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#865771, 0.0))), isnull(qty#... [43164] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112617 { id="cluster_112617"; isCluster="true"; label="Exchange"; 43260 [id="node_43260" labelType="html" label="ShuffledRowRDD [43260] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112612 { id="cluster_112612"; isCluster="true"; label="WholeStageCodegen (6)"; 43261 [id="node_43261" labelType="html" label="MapPartitionsRDD [43261] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112611 { id="cluster_112611"; isCluster="true"; label="SortAggregate"; 43262 [id="node_43262" labelType="html" label="MapPartitionsRDD [43262] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112610 { id="cluster_112610"; isCluster="true"; label="InMemoryTableScan"; 43263 [id="node_43263" labelType="html" label="MapPartitionsRDD [43263] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43264 [id="node_43264" labelType="html" label="SortAggregate(key=[demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541], functions=[first(kpis#868569, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#868560, demandChannel#868540, demandStream#868541, kpis#868702])\n+- *(6) Sort [demandChannel#868540 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#868560 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#868541 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541, 37), ENSURE_REQUIREMENTS, [plan_id=1384066]\n +- SortAggregate(key=[demandChannel#868540, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#868560)) AS qty#868560, worklistShardItemId#815741L, demandStream#868541], functions=[partial_first(kpis#868569, false)], output=[demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541, first#86877... [43264] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112777 { id="cluster_112777"; isCluster="true"; label="InMemoryTableScan"; 43302 [id="node_43302" labelType="html" label="MapPartitionsRDD [43302] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43303 [id="node_43303" labelType="html" label="MapPartitionsRDD [43303] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43304 [id="node_43304" labelType="html" label="MapPartitionsRDD [43304] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112773 { id="cluster_112773"; isCluster="true"; label="WholeStageCodegen (1)"; 43305 [id="node_43305" labelType="html" label="MapPartitionsRDD [43305] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112781 { id="cluster_112781"; isCluster="true"; label="InMemoryTableScan"; 43306 [id="node_43306" labelType="html" label="MapPartitionsRDD [43306] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43307 [id="node_43307" labelType="html" label="MapPartitionsRDD [43307] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43308 [id="node_43308" labelType="html" label="MapPartitionsRDD [43308] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112778 { id="cluster_112778"; isCluster="true"; label="WholeStageCodegen (2)"; 43309 [id="node_43309" labelType="html" label="MapPartitionsRDD [43309] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112772 { id="cluster_112772"; isCluster="true"; label="Union"; 43310 [id="node_43310" labelType="html" label="UnionRDD [43310] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112748 { id="cluster_112748"; isCluster="true"; label="WholeStageCodegen (5)"; 43311 [id="node_43311" labelType="html" label="MapPartitionsRDD [43311] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112747 { id="cluster_112747"; isCluster="true"; label="InMemoryTableScan"; 43312 [id="node_43312" labelType="html" label="MapPartitionsRDD [43312] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43313 [id="node_43313" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#869373, qty#815747, demandChannel#866004, demandStream#866005, kpis#866039]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#869470, worklistShardItemId#869471L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#866004, demandStream#866005, kpis#866039]\n : : +- *(1) Filter ((NOT isNewlyCalculated#866007 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#866004, demandStream#866005, isNewlyCalculated#866007, kpis#866039, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#866007, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#866004, demandStream#866005... [43313] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112806 { id="cluster_112806"; isCluster="true"; label="InMemoryTableScan"; 43322 [id="node_43322" labelType="html" label="MapPartitionsRDD [43322] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43323 [id="node_43323" labelType="html" label="MapPartitionsRDD [43323] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43324 [id="node_43324" labelType="html" label="MapPartitionsRDD [43324] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43126->43127; 43138->43139; 43142->43143; 43139->43144; 43143->43144; 43144->43145; 43145->43146; 43146->43147; 43154->43155; 43127->43156; 43155->43156; 43156->43157; 43147->43158; 43158->43159; 43159->43160; 43160->43161; 43157->43162; 43161->43162; 43162->43163; 43163->43164; 43260->43261; 43261->43262; 43262->43263; 43263->43264; 43164->43302; 43302->43303; 43303->43304; 43304->43305; 43264->43306; 43306->43307; 43307->43308; 43308->43309; 43305->43310; 43309->43310; 43310->43311; 43311->43312; 43312->43313; 43313->43322; 43322->43323; 43323->43324; }