digraph G { id="graph_104713"; subgraph graph_stage_104713 { id="graph_stage_104713"; isCluster="true"; label="Stage 104713"; subgraph cluster_130377 { id="cluster_130377"; isCluster="true"; label="Exchange"; 49983 [id="node_49983" labelType="html" label="ShuffledRowRDD [49983] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130374 { id="cluster_130374"; isCluster="true"; label="WholeStageCodegen (1)"; 49984 [id="node_49984" labelType="html" label="MapPartitionsRDD [49984] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130397 { id="cluster_130397"; isCluster="true"; label="Exchange"; 49995 [id="node_49995" labelType="html" label="ShuffledRowRDD [49995] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130394 { id="cluster_130394"; isCluster="true"; label="WholeStageCodegen (4)"; 49996 [id="node_49996" labelType="html" label="MapPartitionsRDD [49996] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130432 { id="cluster_130432"; isCluster="true"; label="Exchange"; 49999 [id="node_49999" labelType="html" label="ShuffledRowRDD [49999] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130429 { id="cluster_130429"; isCluster="true"; label="WholeStageCodegen (6)"; 50000 [id="node_50000" labelType="html" label="MapPartitionsRDD [50000] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130386 { id="cluster_130386"; isCluster="true"; label="WholeStageCodegen (7)"; 50001 [id="node_50001" labelType="html" label="ZippedPartitionsRDD2 [50001] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50002 [id="node_50002" labelType="html" label="MapPartitionsRDD [50002] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130385 { id="cluster_130385"; isCluster="true"; label="InMemoryTableScan"; 50003 [id="node_50003" labelType="html" label="MapPartitionsRDD [50003] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50004 [id="node_50004" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#1000981 AS qty#1000983, demandChannel#1000976, demandStream#1000977, cachedKpis#1000982 AS kpis#1000984]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#1000980L, cachedShardId#1000979], 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=1630480]\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=1630476]\n : +- ... [50004] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130383 { id="cluster_130383"; isCluster="true"; label="Exchange"; 50011 [id="node_50011" labelType="html" label="ShuffledRowRDD [50011] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130380 { id="cluster_130380"; isCluster="true"; label="WholeStageCodegen (4)"; 50012 [id="node_50012" labelType="html" label="MapPartitionsRDD [50012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130366 { id="cluster_130366"; isCluster="true"; label="WholeStageCodegen (5)"; 50013 [id="node_50013" labelType="html" label="ZippedPartitionsRDD2 [50013] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50014 [id="node_50014" labelType="html" label="MapPartitionsRDD [50014] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130447 { id="cluster_130447"; isCluster="true"; label="InMemoryTableScan"; 50015 [id="node_50015" labelType="html" label="MapPartitionsRDD [50015] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50016 [id="node_50016" labelType="html" label="MapPartitionsRDD [50016] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50017 [id="node_50017" labelType="html" label="MapPartitionsRDD [50017] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130444 { id="cluster_130444"; isCluster="true"; label="WholeStageCodegen (6)"; 50018 [id="node_50018" labelType="html" label="MapPartitionsRDD [50018] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130365 { id="cluster_130365"; isCluster="true"; label="Union"; 50019 [id="node_50019" labelType="html" label="UnionRDD [50019] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130364 { id="cluster_130364"; isCluster="true"; label="InMemoryTableScan"; 50020 [id="node_50020" labelType="html" label="MapPartitionsRDD [50020] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50021 [id="node_50021" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#1001216, null AS demandStream#1001217, [] AS kpis#1001251, true AS isNewlyCalculated#1001219]\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#1001208, ), isnull(shardId#1001208), coalesce(worklistShardItemId#1001209L, 0), isnull(worklistShardItemId#1001209L), coalesce(version#1001210, 0), isnull(version#1001210), coalesce(product#1001211, ), isnull(product#1001211), coalesce(plant#1001212, ), isnull(plant#1001212), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1000983, 0.0)... [50021] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130654 { id="cluster_130654"; isCluster="true"; label="Exchange"; 50117 [id="node_50117" labelType="html" label="ShuffledRowRDD [50117] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130648 { id="cluster_130648"; isCluster="true"; label="WholeStageCodegen (6)"; 50118 [id="node_50118" labelType="html" label="MapPartitionsRDD [50118] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130647 { id="cluster_130647"; isCluster="true"; label="SortAggregate"; 50119 [id="node_50119" labelType="html" label="MapPartitionsRDD [50119] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130646 { id="cluster_130646"; isCluster="true"; label="InMemoryTableScan"; 50120 [id="node_50120" labelType="html" label="MapPartitionsRDD [50120] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50121 [id="node_50121" labelType="html" label="SortAggregate(key=[demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStream#1003753], functions=[first(kpis#1003781, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#1003772, demandChannel#1003752, demandStream#1003753, kpis#1003914])\n+- *(6) Sort [demandChannel#1003752 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#1003772 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#1003753 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStream#1003753, 37), ENSURE_REQUIREMENTS, [plan_id=1631410]\n +- SortAggregate(key=[demandChannel#1003752, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#1003772)) AS qty#1003772, worklistShardItemId#943632L, demandStream#1003753], functions=[partial_first(kpis#1003781, false)], output=[demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStrea... [50121] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130813 { id="cluster_130813"; isCluster="true"; label="InMemoryTableScan"; 50159 [id="node_50159" labelType="html" label="MapPartitionsRDD [50159] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50160 [id="node_50160" labelType="html" label="MapPartitionsRDD [50160] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50161 [id="node_50161" labelType="html" label="MapPartitionsRDD [50161] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130809 { id="cluster_130809"; isCluster="true"; label="WholeStageCodegen (1)"; 50162 [id="node_50162" labelType="html" label="MapPartitionsRDD [50162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130817 { id="cluster_130817"; isCluster="true"; label="InMemoryTableScan"; 50163 [id="node_50163" labelType="html" label="MapPartitionsRDD [50163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50164 [id="node_50164" labelType="html" label="MapPartitionsRDD [50164] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50165 [id="node_50165" labelType="html" label="MapPartitionsRDD [50165] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130814 { id="cluster_130814"; isCluster="true"; label="WholeStageCodegen (2)"; 50166 [id="node_50166" labelType="html" label="MapPartitionsRDD [50166] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130808 { id="cluster_130808"; isCluster="true"; label="Union"; 50167 [id="node_50167" labelType="html" label="UnionRDD [50167] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130784 { id="cluster_130784"; isCluster="true"; label="WholeStageCodegen (5)"; 50168 [id="node_50168" labelType="html" label="MapPartitionsRDD [50168] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130783 { id="cluster_130783"; isCluster="true"; label="InMemoryTableScan"; 50169 [id="node_50169" labelType="html" label="MapPartitionsRDD [50169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50170 [id="node_50170" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#1004585, qty#943638, demandChannel#1001216, demandStream#1001217, kpis#1001251]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#1004682, worklistShardItemId#1004683L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#1001216, demandStream#1001217, kpis#1001251]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1001219 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#1001216, demandStream#1001217, isNewlyCalculated#1001219, kpis#1001251, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#1001219, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#1001216, dem... [50170] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130842 { id="cluster_130842"; isCluster="true"; label="InMemoryTableScan"; 50179 [id="node_50179" labelType="html" label="MapPartitionsRDD [50179] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50180 [id="node_50180" labelType="html" label="MapPartitionsRDD [50180] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50181 [id="node_50181" labelType="html" label="MapPartitionsRDD [50181] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49983->49984; 49995->49996; 49999->50000; 49996->50001; 50000->50001; 50001->50002; 50002->50003; 50003->50004; 50011->50012; 49984->50013; 50012->50013; 50013->50014; 50004->50015; 50015->50016; 50016->50017; 50017->50018; 50014->50019; 50018->50019; 50019->50020; 50020->50021; 50117->50118; 50118->50119; 50119->50120; 50120->50121; 50021->50159; 50159->50160; 50160->50161; 50161->50162; 50121->50163; 50163->50164; 50164->50165; 50165->50166; 50162->50167; 50166->50167; 50167->50168; 50168->50169; 50169->50170; 50170->50179; 50179->50180; 50180->50181; }