digraph G { id="graph_102793"; subgraph graph_stage_102793 { id="graph_stage_102793"; isCluster="true"; label="Stage 102793"; subgraph cluster_128514 { id="cluster_128514"; isCluster="true"; label="Exchange"; 49191 [id="node_49191" labelType="html" label="ShuffledRowRDD [49191] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128511 { id="cluster_128511"; isCluster="true"; label="WholeStageCodegen (1)"; 49192 [id="node_49192" labelType="html" label="MapPartitionsRDD [49192] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128534 { id="cluster_128534"; isCluster="true"; label="Exchange"; 49203 [id="node_49203" labelType="html" label="ShuffledRowRDD [49203] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128531 { id="cluster_128531"; isCluster="true"; label="WholeStageCodegen (4)"; 49204 [id="node_49204" labelType="html" label="MapPartitionsRDD [49204] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128569 { id="cluster_128569"; isCluster="true"; label="Exchange"; 49207 [id="node_49207" labelType="html" label="ShuffledRowRDD [49207] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128566 { id="cluster_128566"; isCluster="true"; label="WholeStageCodegen (6)"; 49208 [id="node_49208" labelType="html" label="MapPartitionsRDD [49208] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128523 { id="cluster_128523"; isCluster="true"; label="WholeStageCodegen (7)"; 49209 [id="node_49209" labelType="html" label="ZippedPartitionsRDD2 [49209] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49210 [id="node_49210" labelType="html" label="MapPartitionsRDD [49210] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128522 { id="cluster_128522"; isCluster="true"; label="InMemoryTableScan"; 49211 [id="node_49211" labelType="html" label="MapPartitionsRDD [49211] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49212 [id="node_49212" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#984307 AS qty#984309, demandChannel#984302, demandStream#984303, cachedKpis#984308 AS kpis#984310]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#984306L, cachedShardId#984305], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1625710]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1625706]\n : +- *(2) Has... [49212] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128520 { id="cluster_128520"; isCluster="true"; label="Exchange"; 49219 [id="node_49219" labelType="html" label="ShuffledRowRDD [49219] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128517 { id="cluster_128517"; isCluster="true"; label="WholeStageCodegen (4)"; 49220 [id="node_49220" labelType="html" label="MapPartitionsRDD [49220] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128503 { id="cluster_128503"; isCluster="true"; label="WholeStageCodegen (5)"; 49221 [id="node_49221" labelType="html" label="ZippedPartitionsRDD2 [49221] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49222 [id="node_49222" labelType="html" label="MapPartitionsRDD [49222] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128584 { id="cluster_128584"; isCluster="true"; label="InMemoryTableScan"; 49223 [id="node_49223" labelType="html" label="MapPartitionsRDD [49223] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49224 [id="node_49224" labelType="html" label="MapPartitionsRDD [49224] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49225 [id="node_49225" labelType="html" label="MapPartitionsRDD [49225] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128581 { id="cluster_128581"; isCluster="true"; label="WholeStageCodegen (6)"; 49226 [id="node_49226" labelType="html" label="MapPartitionsRDD [49226] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128502 { id="cluster_128502"; isCluster="true"; label="Union"; 49227 [id="node_49227" labelType="html" label="UnionRDD [49227] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128501 { id="cluster_128501"; isCluster="true"; label="InMemoryTableScan"; 49228 [id="node_49228" labelType="html" label="MapPartitionsRDD [49228] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49229 [id="node_49229" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#984542, null AS demandStream#984543, [] AS kpis#984577, true AS isNewlyCalculated#984545]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#984534, ), isnull(shardId#984534), coalesce(worklistShardItemId#984535L, 0), isnull(worklistShardItemId#984535L), coalesce(version#984536, 0), isnull(version#984536), coalesce(product#984537, ), isnull(product#984537), coalesce(plant#984538, ), isnull(plant#984538), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#984309, 0.0))), isnull(qty#... [49229] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128790 { id="cluster_128790"; isCluster="true"; label="Exchange"; 49325 [id="node_49325" labelType="html" label="ShuffledRowRDD [49325] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128785 { id="cluster_128785"; isCluster="true"; label="WholeStageCodegen (6)"; 49326 [id="node_49326" labelType="html" label="MapPartitionsRDD [49326] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128784 { id="cluster_128784"; isCluster="true"; label="SortAggregate"; 49327 [id="node_49327" labelType="html" label="MapPartitionsRDD [49327] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128783 { id="cluster_128783"; isCluster="true"; label="InMemoryTableScan"; 49328 [id="node_49328" labelType="html" label="MapPartitionsRDD [49328] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49329 [id="node_49329" labelType="html" label="SortAggregate(key=[demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079], functions=[first(kpis#987107, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#987098, demandChannel#987078, demandStream#987079, kpis#987240])\n+- *(6) Sort [demandChannel#987078 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#987098 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#987079 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079, 37), ENSURE_REQUIREMENTS, [plan_id=1626640]\n +- SortAggregate(key=[demandChannel#987078, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#987098)) AS qty#987098, worklistShardItemId#943632L, demandStream#987079], functions=[partial_first(kpis#987107, false)], output=[demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079, first#98731... [49329] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128950 { id="cluster_128950"; isCluster="true"; label="InMemoryTableScan"; 49367 [id="node_49367" labelType="html" label="MapPartitionsRDD [49367] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49368 [id="node_49368" labelType="html" label="MapPartitionsRDD [49368] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49369 [id="node_49369" labelType="html" label="MapPartitionsRDD [49369] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128946 { id="cluster_128946"; isCluster="true"; label="WholeStageCodegen (1)"; 49370 [id="node_49370" labelType="html" label="MapPartitionsRDD [49370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128954 { id="cluster_128954"; isCluster="true"; label="InMemoryTableScan"; 49371 [id="node_49371" labelType="html" label="MapPartitionsRDD [49371] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49372 [id="node_49372" labelType="html" label="MapPartitionsRDD [49372] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49373 [id="node_49373" labelType="html" label="MapPartitionsRDD [49373] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128951 { id="cluster_128951"; isCluster="true"; label="WholeStageCodegen (2)"; 49374 [id="node_49374" labelType="html" label="MapPartitionsRDD [49374] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128945 { id="cluster_128945"; isCluster="true"; label="Union"; 49375 [id="node_49375" labelType="html" label="UnionRDD [49375] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128921 { id="cluster_128921"; isCluster="true"; label="WholeStageCodegen (5)"; 49376 [id="node_49376" labelType="html" label="MapPartitionsRDD [49376] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128920 { id="cluster_128920"; isCluster="true"; label="InMemoryTableScan"; 49377 [id="node_49377" labelType="html" label="MapPartitionsRDD [49377] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49378 [id="node_49378" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#987911, qty#943638, demandChannel#984542, demandStream#984543, kpis#984577]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#988008, worklistShardItemId#988009L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#984542, demandStream#984543, kpis#984577]\n : : +- *(1) Filter ((NOT isNewlyCalculated#984545 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#984542, demandStream#984543, isNewlyCalculated#984545, kpis#984577, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#984545, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#984542, demandStream#984543... [49378] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128979 { id="cluster_128979"; isCluster="true"; label="InMemoryTableScan"; 49387 [id="node_49387" labelType="html" label="MapPartitionsRDD [49387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49388 [id="node_49388" labelType="html" label="MapPartitionsRDD [49388] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49389 [id="node_49389" labelType="html" label="MapPartitionsRDD [49389] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49191->49192; 49203->49204; 49207->49208; 49204->49209; 49208->49209; 49209->49210; 49210->49211; 49211->49212; 49219->49220; 49192->49221; 49220->49221; 49221->49222; 49212->49223; 49223->49224; 49224->49225; 49225->49226; 49222->49227; 49226->49227; 49227->49228; 49228->49229; 49325->49326; 49326->49327; 49327->49328; 49328->49329; 49229->49367; 49367->49368; 49368->49369; 49369->49370; 49329->49371; 49371->49372; 49372->49373; 49373->49374; 49370->49375; 49374->49375; 49375->49376; 49376->49377; 49377->49378; 49378->49387; 49387->49388; 49388->49389; }