digraph G { id="graph_109143"; subgraph graph_stage_109143 { id="graph_stage_109143"; isCluster="true"; label="Stage 109143"; subgraph cluster_136651 { id="cluster_136651"; isCluster="true"; label="Exchange"; 52414 [id="node_52414" labelType="html" label="ShuffledRowRDD [52414] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136648 { id="cluster_136648"; isCluster="true"; label="WholeStageCodegen (1)"; 52415 [id="node_52415" labelType="html" label="MapPartitionsRDD [52415] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136671 { id="cluster_136671"; isCluster="true"; label="Exchange"; 52426 [id="node_52426" labelType="html" label="ShuffledRowRDD [52426] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136668 { id="cluster_136668"; isCluster="true"; label="WholeStageCodegen (4)"; 52427 [id="node_52427" labelType="html" label="MapPartitionsRDD [52427] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136706 { id="cluster_136706"; isCluster="true"; label="Exchange"; 52430 [id="node_52430" labelType="html" label="ShuffledRowRDD [52430] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136703 { id="cluster_136703"; isCluster="true"; label="WholeStageCodegen (6)"; 52431 [id="node_52431" labelType="html" label="MapPartitionsRDD [52431] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136660 { id="cluster_136660"; isCluster="true"; label="WholeStageCodegen (7)"; 52432 [id="node_52432" labelType="html" label="ZippedPartitionsRDD2 [52432] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52433 [id="node_52433" labelType="html" label="MapPartitionsRDD [52433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136659 { id="cluster_136659"; isCluster="true"; label="InMemoryTableScan"; 52434 [id="node_52434" labelType="html" label="MapPartitionsRDD [52434] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52435 [id="node_52435" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1050418 AS qty#1050420, demandChannel#1050413, demandStream#1050414, cachedKpis#1050419 AS kpis#1050421]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1050417L, cachedShardId#1050416], 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=1684687]\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... [52435] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136657 { id="cluster_136657"; isCluster="true"; label="Exchange"; 52442 [id="node_52442" labelType="html" label="ShuffledRowRDD [52442] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136654 { id="cluster_136654"; isCluster="true"; label="WholeStageCodegen (4)"; 52443 [id="node_52443" labelType="html" label="MapPartitionsRDD [52443] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136640 { id="cluster_136640"; isCluster="true"; label="WholeStageCodegen (5)"; 52444 [id="node_52444" labelType="html" label="ZippedPartitionsRDD2 [52444] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52445 [id="node_52445" labelType="html" label="MapPartitionsRDD [52445] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136721 { id="cluster_136721"; isCluster="true"; label="InMemoryTableScan"; 52446 [id="node_52446" labelType="html" label="MapPartitionsRDD [52446] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52447 [id="node_52447" labelType="html" label="MapPartitionsRDD [52447] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52448 [id="node_52448" labelType="html" label="MapPartitionsRDD [52448] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136718 { id="cluster_136718"; isCluster="true"; label="WholeStageCodegen (6)"; 52449 [id="node_52449" labelType="html" label="MapPartitionsRDD [52449] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136639 { id="cluster_136639"; isCluster="true"; label="Union"; 52450 [id="node_52450" labelType="html" label="UnionRDD [52450] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136638 { id="cluster_136638"; isCluster="true"; label="InMemoryTableScan"; 52451 [id="node_52451" labelType="html" label="MapPartitionsRDD [52451] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52452 [id="node_52452" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1050653, null AS demandStream#1050654, [] AS kpis#1050688, true AS isNewlyCalculated#1050656]\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#1050645, ), isnull(shardId#1050645), coalesce(worklistShardItemId#1050646L, 0), isnull(worklistShardItemId#1050646L), coalesce(version#1050647, 0), isnull(version#1050647), coalesce(product#1050648, ), isnull(product#1050648), coalesce(plant#1050649, ), isnull(plant#1050649), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52452] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136928 { id="cluster_136928"; isCluster="true"; label="Exchange"; 52548 [id="node_52548" labelType="html" label="ShuffledRowRDD [52548] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136922 { id="cluster_136922"; isCluster="true"; label="WholeStageCodegen (6)"; 52549 [id="node_52549" labelType="html" label="MapPartitionsRDD [52549] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136921 { id="cluster_136921"; isCluster="true"; label="SortAggregate"; 52550 [id="node_52550" labelType="html" label="MapPartitionsRDD [52550] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136920 { id="cluster_136920"; isCluster="true"; label="InMemoryTableScan"; 52551 [id="node_52551" labelType="html" label="MapPartitionsRDD [52551] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52552 [id="node_52552" labelType="html" label="SortAggregate(key=[demandChannel#1053189, shardId#1011815, qty#1053209, worklistShardItemId#1011816L, demandStream#1053190], functions=[first(kpis#1053218, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1053209, demandChannel#1053189, demandStream#1053190, kpis#1053351])\n+- *(6) Sort [demandChannel#1053189 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1053209 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1053190 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1053189, shardId#1011815, qty#1053209, worklistShardItemId#1011816L, demandStream#1053190, 37), ENSURE_REQUIREMENTS, [plan_id=1685617]\n +- SortAggregate(key=[demandChannel#1053189, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1053209)) AS qty#1053209, worklistShardItemId#1011816L, demandStream#1053190], functions=[partial_first(kpis#1053218, false)], output=[demandChannel#1053189, shardId#1011815, qty#1053209, worklistShardItemId#1011816L,... [52552] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137087 { id="cluster_137087"; isCluster="true"; label="InMemoryTableScan"; 52590 [id="node_52590" labelType="html" label="MapPartitionsRDD [52590] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52591 [id="node_52591" labelType="html" label="MapPartitionsRDD [52591] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52592 [id="node_52592" labelType="html" label="MapPartitionsRDD [52592] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137083 { id="cluster_137083"; isCluster="true"; label="WholeStageCodegen (1)"; 52593 [id="node_52593" labelType="html" label="MapPartitionsRDD [52593] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137091 { id="cluster_137091"; isCluster="true"; label="InMemoryTableScan"; 52594 [id="node_52594" labelType="html" label="MapPartitionsRDD [52594] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52595 [id="node_52595" labelType="html" label="MapPartitionsRDD [52595] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52596 [id="node_52596" labelType="html" label="MapPartitionsRDD [52596] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137088 { id="cluster_137088"; isCluster="true"; label="WholeStageCodegen (2)"; 52597 [id="node_52597" labelType="html" label="MapPartitionsRDD [52597] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137082 { id="cluster_137082"; isCluster="true"; label="Union"; 52598 [id="node_52598" labelType="html" label="UnionRDD [52598] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137058 { id="cluster_137058"; isCluster="true"; label="WholeStageCodegen (5)"; 52599 [id="node_52599" labelType="html" label="MapPartitionsRDD [52599] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137057 { id="cluster_137057"; isCluster="true"; label="InMemoryTableScan"; 52600 [id="node_52600" labelType="html" label="MapPartitionsRDD [52600] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52601 [id="node_52601" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1054022, qty#1011822, demandChannel#1050653, demandStream#1050654, kpis#1050688]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1054119, worklistShardItemId#1054120L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1050653, demandStream#1050654, kpis#1050688]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1050656 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1050653, demandStream#1050654, isNewlyCalculated#1050656, kpis#1050688, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1050656, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [52601] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52602 [id="node_52602" labelType="html" label="MapPartitionsRDD [52602] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52603 [id="node_52603" labelType="html" label="MapPartitionsRDD [52603] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52604 [id="node_52604" labelType="html" label="MapPartitionsRDD [52604] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137056 { id="cluster_137056"; isCluster="true"; label="CollectLimit"; 52605 [id="node_52605" labelType="html" label="MapPartitionsRDD [52605] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52606 [id="node_52606" labelType="html" label="MapPartitionsRDD [52606] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52414->52415; 52426->52427; 52430->52431; 52427->52432; 52431->52432; 52432->52433; 52433->52434; 52434->52435; 52442->52443; 52415->52444; 52443->52444; 52444->52445; 52435->52446; 52446->52447; 52447->52448; 52448->52449; 52445->52450; 52449->52450; 52450->52451; 52451->52452; 52548->52549; 52549->52550; 52550->52551; 52551->52552; 52452->52590; 52590->52591; 52591->52592; 52592->52593; 52552->52594; 52594->52595; 52595->52596; 52596->52597; 52593->52598; 52597->52598; 52598->52599; 52599->52600; 52600->52601; 52601->52602; 52602->52603; 52603->52604; 52604->52605; 52605->52606; }