digraph G { id="graph_105569"; subgraph graph_stage_105569 { id="graph_stage_105569"; isCluster="true"; label="Stage 105569"; subgraph cluster_130998 { id="cluster_130998"; isCluster="true"; label="Exchange"; 50247 [id="node_50247" labelType="html" label="ShuffledRowRDD [50247] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130995 { id="cluster_130995"; isCluster="true"; label="WholeStageCodegen (1)"; 50248 [id="node_50248" labelType="html" label="MapPartitionsRDD [50248] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131018 { id="cluster_131018"; isCluster="true"; label="Exchange"; 50259 [id="node_50259" labelType="html" label="ShuffledRowRDD [50259] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131015 { id="cluster_131015"; isCluster="true"; label="WholeStageCodegen (4)"; 50260 [id="node_50260" labelType="html" label="MapPartitionsRDD [50260] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131053 { id="cluster_131053"; isCluster="true"; label="Exchange"; 50263 [id="node_50263" labelType="html" label="ShuffledRowRDD [50263] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131050 { id="cluster_131050"; isCluster="true"; label="WholeStageCodegen (6)"; 50264 [id="node_50264" labelType="html" label="MapPartitionsRDD [50264] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131007 { id="cluster_131007"; isCluster="true"; label="WholeStageCodegen (7)"; 50265 [id="node_50265" labelType="html" label="ZippedPartitionsRDD2 [50265] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50266 [id="node_50266" labelType="html" label="MapPartitionsRDD [50266] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131006 { id="cluster_131006"; isCluster="true"; label="InMemoryTableScan"; 50267 [id="node_50267" labelType="html" label="MapPartitionsRDD [50267] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50268 [id="node_50268" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#1006539 AS qty#1006541, demandChannel#1006534, demandStream#1006535, cachedKpis#1006540 AS kpis#1006542]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#1006538L, cachedShardId#1006537], 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=1632055]\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=1632051]\n : +- ... [50268] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131004 { id="cluster_131004"; isCluster="true"; label="Exchange"; 50275 [id="node_50275" labelType="html" label="ShuffledRowRDD [50275] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131001 { id="cluster_131001"; isCluster="true"; label="WholeStageCodegen (4)"; 50276 [id="node_50276" labelType="html" label="MapPartitionsRDD [50276] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130987 { id="cluster_130987"; isCluster="true"; label="WholeStageCodegen (5)"; 50277 [id="node_50277" labelType="html" label="ZippedPartitionsRDD2 [50277] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50278 [id="node_50278" labelType="html" label="MapPartitionsRDD [50278] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131068 { id="cluster_131068"; isCluster="true"; label="InMemoryTableScan"; 50279 [id="node_50279" labelType="html" label="MapPartitionsRDD [50279] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50280 [id="node_50280" labelType="html" label="MapPartitionsRDD [50280] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50281 [id="node_50281" labelType="html" label="MapPartitionsRDD [50281] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131065 { id="cluster_131065"; isCluster="true"; label="WholeStageCodegen (6)"; 50282 [id="node_50282" labelType="html" label="MapPartitionsRDD [50282] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130986 { id="cluster_130986"; isCluster="true"; label="Union"; 50283 [id="node_50283" labelType="html" label="UnionRDD [50283] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130985 { id="cluster_130985"; isCluster="true"; label="InMemoryTableScan"; 50284 [id="node_50284" labelType="html" label="MapPartitionsRDD [50284] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50285 [id="node_50285" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#1006774, null AS demandStream#1006775, [] AS kpis#1006809, true AS isNewlyCalculated#1006777]\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#1006766, ), isnull(shardId#1006766), coalesce(worklistShardItemId#1006767L, 0), isnull(worklistShardItemId#1006767L), coalesce(version#1006768, 0), isnull(version#1006768), coalesce(product#1006769, ), isnull(product#1006769), coalesce(plant#1006770, ), isnull(plant#1006770), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1006541, 0.0)... [50285] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131274 { id="cluster_131274"; isCluster="true"; label="Exchange"; 50381 [id="node_50381" labelType="html" label="ShuffledRowRDD [50381] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131269 { id="cluster_131269"; isCluster="true"; label="WholeStageCodegen (6)"; 50382 [id="node_50382" labelType="html" label="MapPartitionsRDD [50382] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131268 { id="cluster_131268"; isCluster="true"; label="SortAggregate"; 50383 [id="node_50383" labelType="html" label="MapPartitionsRDD [50383] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131267 { id="cluster_131267"; isCluster="true"; label="InMemoryTableScan"; 50384 [id="node_50384" labelType="html" label="MapPartitionsRDD [50384] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50385 [id="node_50385" labelType="html" label="SortAggregate(key=[demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStream#1009311], functions=[first(kpis#1009339, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#1009330, demandChannel#1009310, demandStream#1009311, kpis#1009472])\n+- *(6) Sort [demandChannel#1009310 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#1009330 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#1009311 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStream#1009311, 37), ENSURE_REQUIREMENTS, [plan_id=1632985]\n +- SortAggregate(key=[demandChannel#1009310, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#1009330)) AS qty#1009330, worklistShardItemId#943632L, demandStream#1009311], functions=[partial_first(kpis#1009339, false)], output=[demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStrea... [50385] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131434 { id="cluster_131434"; isCluster="true"; label="InMemoryTableScan"; 50423 [id="node_50423" labelType="html" label="MapPartitionsRDD [50423] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50424 [id="node_50424" labelType="html" label="MapPartitionsRDD [50424] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50425 [id="node_50425" labelType="html" label="MapPartitionsRDD [50425] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131430 { id="cluster_131430"; isCluster="true"; label="WholeStageCodegen (1)"; 50426 [id="node_50426" labelType="html" label="MapPartitionsRDD [50426] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131438 { id="cluster_131438"; isCluster="true"; label="InMemoryTableScan"; 50427 [id="node_50427" labelType="html" label="MapPartitionsRDD [50427] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50428 [id="node_50428" labelType="html" label="MapPartitionsRDD [50428] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50429 [id="node_50429" labelType="html" label="MapPartitionsRDD [50429] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131435 { id="cluster_131435"; isCluster="true"; label="WholeStageCodegen (2)"; 50430 [id="node_50430" labelType="html" label="MapPartitionsRDD [50430] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131429 { id="cluster_131429"; isCluster="true"; label="Union"; 50431 [id="node_50431" labelType="html" label="UnionRDD [50431] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131405 { id="cluster_131405"; isCluster="true"; label="WholeStageCodegen (5)"; 50432 [id="node_50432" labelType="html" label="MapPartitionsRDD [50432] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131404 { id="cluster_131404"; isCluster="true"; label="InMemoryTableScan"; 50433 [id="node_50433" labelType="html" label="MapPartitionsRDD [50433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50434 [id="node_50434" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#1010143, qty#943638, demandChannel#1006774, demandStream#1006775, kpis#1006809]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#1010240, worklistShardItemId#1010241L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#1006774, demandStream#1006775, kpis#1006809]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1006777 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#1006774, demandStream#1006775, isNewlyCalculated#1006777, kpis#1006809, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#1006777, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#1006774, dem... [50434] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50435 [id="node_50435" labelType="html" label="MapPartitionsRDD [50435] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50436 [id="node_50436" labelType="html" label="MapPartitionsRDD [50436] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50437 [id="node_50437" labelType="html" label="MapPartitionsRDD [50437] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131403 { id="cluster_131403"; isCluster="true"; label="CollectLimit"; 50438 [id="node_50438" labelType="html" label="MapPartitionsRDD [50438] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50439 [id="node_50439" labelType="html" label="MapPartitionsRDD [50439] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 50247->50248; 50259->50260; 50263->50264; 50260->50265; 50264->50265; 50265->50266; 50266->50267; 50267->50268; 50275->50276; 50248->50277; 50276->50277; 50277->50278; 50268->50279; 50279->50280; 50280->50281; 50281->50282; 50278->50283; 50282->50283; 50283->50284; 50284->50285; 50381->50382; 50382->50383; 50383->50384; 50384->50385; 50285->50423; 50423->50424; 50424->50425; 50425->50426; 50385->50427; 50427->50428; 50428->50429; 50429->50430; 50426->50431; 50430->50431; 50431->50432; 50432->50433; 50433->50434; 50434->50435; 50435->50436; 50436->50437; 50437->50438; 50438->50439; }