digraph G { id="graph_108287"; subgraph graph_stage_108287 { id="graph_stage_108287"; isCluster="true"; label="Stage 108287"; subgraph cluster_136030 { id="cluster_136030"; isCluster="true"; label="Exchange"; 52150 [id="node_52150" labelType="html" label="ShuffledRowRDD [52150] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136027 { id="cluster_136027"; isCluster="true"; label="WholeStageCodegen (1)"; 52151 [id="node_52151" labelType="html" label="MapPartitionsRDD [52151] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136050 { id="cluster_136050"; isCluster="true"; label="Exchange"; 52162 [id="node_52162" labelType="html" label="ShuffledRowRDD [52162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136047 { id="cluster_136047"; isCluster="true"; label="WholeStageCodegen (4)"; 52163 [id="node_52163" labelType="html" label="MapPartitionsRDD [52163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136079 { id="cluster_136079"; isCluster="true"; label="Exchange"; 52166 [id="node_52166" labelType="html" label="ShuffledRowRDD [52166] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136076 { id="cluster_136076"; isCluster="true"; label="WholeStageCodegen (6)"; 52167 [id="node_52167" labelType="html" label="MapPartitionsRDD [52167] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136039 { id="cluster_136039"; isCluster="true"; label="WholeStageCodegen (7)"; 52168 [id="node_52168" labelType="html" label="ZippedPartitionsRDD2 [52168] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52169 [id="node_52169" labelType="html" label="MapPartitionsRDD [52169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136038 { id="cluster_136038"; isCluster="true"; label="InMemoryTableScan"; 52170 [id="node_52170" labelType="html" label="MapPartitionsRDD [52170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52171 [id="node_52171" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1044860 AS qty#1044862, demandChannel#1044855, demandStream#1044856, cachedKpis#1044861 AS kpis#1044863]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1044859L, cachedShardId#1044858], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1683138]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [52171] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136036 { id="cluster_136036"; isCluster="true"; label="Exchange"; 52178 [id="node_52178" labelType="html" label="ShuffledRowRDD [52178] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136033 { id="cluster_136033"; isCluster="true"; label="WholeStageCodegen (4)"; 52179 [id="node_52179" labelType="html" label="MapPartitionsRDD [52179] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136019 { id="cluster_136019"; isCluster="true"; label="WholeStageCodegen (5)"; 52180 [id="node_52180" labelType="html" label="ZippedPartitionsRDD2 [52180] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52181 [id="node_52181" labelType="html" label="MapPartitionsRDD [52181] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136100 { id="cluster_136100"; isCluster="true"; label="InMemoryTableScan"; 52182 [id="node_52182" labelType="html" label="MapPartitionsRDD [52182] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52183 [id="node_52183" labelType="html" label="MapPartitionsRDD [52183] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52184 [id="node_52184" labelType="html" label="MapPartitionsRDD [52184] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136097 { id="cluster_136097"; isCluster="true"; label="WholeStageCodegen (6)"; 52185 [id="node_52185" labelType="html" label="MapPartitionsRDD [52185] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136018 { id="cluster_136018"; isCluster="true"; label="Union"; 52186 [id="node_52186" labelType="html" label="UnionRDD [52186] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136017 { id="cluster_136017"; isCluster="true"; label="InMemoryTableScan"; 52187 [id="node_52187" labelType="html" label="MapPartitionsRDD [52187] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52188 [id="node_52188" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1045095, null AS demandStream#1045096, [] AS kpis#1045130, true AS isNewlyCalculated#1045098]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1045087, ), isnull(shardId#1045087), coalesce(worklistShardItemId#1045088L, 0), isnull(worklistShardItemId#1045088L), coalesce(version#1045089, 0), isnull(version#1045089), coalesce(product#1045090, ), isnull(product#1045090), coalesce(plant#1045091, ), isnull(plant#1045091), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52188] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136307 { id="cluster_136307"; isCluster="true"; label="Exchange"; 52284 [id="node_52284" labelType="html" label="ShuffledRowRDD [52284] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136301 { id="cluster_136301"; isCluster="true"; label="WholeStageCodegen (6)"; 52285 [id="node_52285" labelType="html" label="MapPartitionsRDD [52285] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136300 { id="cluster_136300"; isCluster="true"; label="SortAggregate"; 52286 [id="node_52286" labelType="html" label="MapPartitionsRDD [52286] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136299 { id="cluster_136299"; isCluster="true"; label="InMemoryTableScan"; 52287 [id="node_52287" labelType="html" label="MapPartitionsRDD [52287] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52288 [id="node_52288" labelType="html" label="SortAggregate(key=[demandChannel#1047631, shardId#1011815, qty#1047651, worklistShardItemId#1011816L, demandStream#1047632], functions=[first(kpis#1047660, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1047651, demandChannel#1047631, demandStream#1047632, kpis#1047793])\n+- *(6) Sort [demandChannel#1047631 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1047651 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1047632 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1047631, shardId#1011815, qty#1047651, worklistShardItemId#1011816L, demandStream#1047632, 37), ENSURE_REQUIREMENTS, [plan_id=1684068]\n +- SortAggregate(key=[demandChannel#1047631, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1047651)) AS qty#1047651, worklistShardItemId#1011816L, demandStream#1047632], functions=[partial_first(kpis#1047660, false)], output=[demandChannel#1047631, shardId#1011815, qty#1047651, worklistShardItemId#1011816L,... [52288] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136466 { id="cluster_136466"; isCluster="true"; label="InMemoryTableScan"; 52326 [id="node_52326" labelType="html" label="MapPartitionsRDD [52326] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52327 [id="node_52327" labelType="html" label="MapPartitionsRDD [52327] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52328 [id="node_52328" labelType="html" label="MapPartitionsRDD [52328] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136462 { id="cluster_136462"; isCluster="true"; label="WholeStageCodegen (1)"; 52329 [id="node_52329" labelType="html" label="MapPartitionsRDD [52329] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136470 { id="cluster_136470"; isCluster="true"; label="InMemoryTableScan"; 52330 [id="node_52330" labelType="html" label="MapPartitionsRDD [52330] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52331 [id="node_52331" labelType="html" label="MapPartitionsRDD [52331] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52332 [id="node_52332" labelType="html" label="MapPartitionsRDD [52332] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136467 { id="cluster_136467"; isCluster="true"; label="WholeStageCodegen (2)"; 52333 [id="node_52333" labelType="html" label="MapPartitionsRDD [52333] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136461 { id="cluster_136461"; isCluster="true"; label="Union"; 52334 [id="node_52334" labelType="html" label="UnionRDD [52334] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136437 { id="cluster_136437"; isCluster="true"; label="WholeStageCodegen (5)"; 52335 [id="node_52335" labelType="html" label="MapPartitionsRDD [52335] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136436 { id="cluster_136436"; isCluster="true"; label="InMemoryTableScan"; 52336 [id="node_52336" labelType="html" label="MapPartitionsRDD [52336] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52337 [id="node_52337" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1048464, qty#1011822, demandChannel#1045095, demandStream#1045096, kpis#1045130]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1048561, worklistShardItemId#1048562L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1045095, demandStream#1045096, kpis#1045130]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1045098 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1045095, demandStream#1045096, isNewlyCalculated#1045098, kpis#1045130, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1045098, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [52337] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136495 { id="cluster_136495"; isCluster="true"; label="InMemoryTableScan"; 52346 [id="node_52346" labelType="html" label="MapPartitionsRDD [52346] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52347 [id="node_52347" labelType="html" label="MapPartitionsRDD [52347] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52348 [id="node_52348" labelType="html" label="MapPartitionsRDD [52348] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52150->52151; 52162->52163; 52166->52167; 52163->52168; 52167->52168; 52168->52169; 52169->52170; 52170->52171; 52178->52179; 52151->52180; 52179->52180; 52180->52181; 52171->52182; 52182->52183; 52183->52184; 52184->52185; 52181->52186; 52185->52186; 52186->52187; 52187->52188; 52284->52285; 52285->52286; 52286->52287; 52287->52288; 52188->52326; 52326->52327; 52327->52328; 52328->52329; 52288->52330; 52330->52331; 52331->52332; 52332->52333; 52329->52334; 52333->52334; 52334->52335; 52335->52336; 52336->52337; 52337->52346; 52346->52347; 52347->52348; }