digraph G { id="graph_106845"; subgraph graph_stage_106845 { id="graph_stage_106845"; isCluster="true"; label="Stage 106845"; subgraph cluster_134788 { id="cluster_134788"; isCluster="true"; label="Exchange"; 51622 [id="node_51622" labelType="html" label="ShuffledRowRDD [51622] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134785 { id="cluster_134785"; isCluster="true"; label="WholeStageCodegen (1)"; 51623 [id="node_51623" labelType="html" label="MapPartitionsRDD [51623] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134808 { id="cluster_134808"; isCluster="true"; label="Exchange"; 51634 [id="node_51634" labelType="html" label="ShuffledRowRDD [51634] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134805 { id="cluster_134805"; isCluster="true"; label="WholeStageCodegen (4)"; 51635 [id="node_51635" labelType="html" label="MapPartitionsRDD [51635] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134843 { id="cluster_134843"; isCluster="true"; label="Exchange"; 51638 [id="node_51638" labelType="html" label="ShuffledRowRDD [51638] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134840 { id="cluster_134840"; isCluster="true"; label="WholeStageCodegen (6)"; 51639 [id="node_51639" labelType="html" label="MapPartitionsRDD [51639] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134797 { id="cluster_134797"; isCluster="true"; label="WholeStageCodegen (7)"; 51640 [id="node_51640" labelType="html" label="ZippedPartitionsRDD2 [51640] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51641 [id="node_51641" labelType="html" label="MapPartitionsRDD [51641] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134796 { id="cluster_134796"; isCluster="true"; label="InMemoryTableScan"; 51642 [id="node_51642" labelType="html" label="MapPartitionsRDD [51642] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51643 [id="node_51643" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1033744 AS qty#1033746, demandChannel#1033739, demandStream#1033740, cachedKpis#1033745 AS kpis#1033747]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1033743L, cachedShardId#1033742], 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=1680014]\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... [51643] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134794 { id="cluster_134794"; isCluster="true"; label="Exchange"; 51650 [id="node_51650" labelType="html" label="ShuffledRowRDD [51650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134791 { id="cluster_134791"; isCluster="true"; label="WholeStageCodegen (4)"; 51651 [id="node_51651" labelType="html" label="MapPartitionsRDD [51651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134777 { id="cluster_134777"; isCluster="true"; label="WholeStageCodegen (5)"; 51652 [id="node_51652" labelType="html" label="ZippedPartitionsRDD2 [51652] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51653 [id="node_51653" labelType="html" label="MapPartitionsRDD [51653] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134858 { id="cluster_134858"; isCluster="true"; label="InMemoryTableScan"; 51654 [id="node_51654" labelType="html" label="MapPartitionsRDD [51654] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51655 [id="node_51655" labelType="html" label="MapPartitionsRDD [51655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51656 [id="node_51656" labelType="html" label="MapPartitionsRDD [51656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134855 { id="cluster_134855"; isCluster="true"; label="WholeStageCodegen (6)"; 51657 [id="node_51657" labelType="html" label="MapPartitionsRDD [51657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134776 { id="cluster_134776"; isCluster="true"; label="Union"; 51658 [id="node_51658" labelType="html" label="UnionRDD [51658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134775 { id="cluster_134775"; isCluster="true"; label="InMemoryTableScan"; 51659 [id="node_51659" labelType="html" label="MapPartitionsRDD [51659] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51660 [id="node_51660" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1033979, null AS demandStream#1033980, [] AS kpis#1034014, true AS isNewlyCalculated#1033982]\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#1033971, ), isnull(shardId#1033971), coalesce(worklistShardItemId#1033972L, 0), isnull(worklistShardItemId#1033972L), coalesce(version#1033973, 0), isnull(version#1033973), coalesce(product#1033974, ), isnull(product#1033974), coalesce(plant#1033975, ), isnull(plant#1033975), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51660] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135065 { id="cluster_135065"; isCluster="true"; label="Exchange"; 51756 [id="node_51756" labelType="html" label="ShuffledRowRDD [51756] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135059 { id="cluster_135059"; isCluster="true"; label="WholeStageCodegen (6)"; 51757 [id="node_51757" labelType="html" label="MapPartitionsRDD [51757] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135058 { id="cluster_135058"; isCluster="true"; label="SortAggregate"; 51758 [id="node_51758" labelType="html" label="MapPartitionsRDD [51758] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135057 { id="cluster_135057"; isCluster="true"; label="InMemoryTableScan"; 51759 [id="node_51759" labelType="html" label="MapPartitionsRDD [51759] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51760 [id="node_51760" labelType="html" label="SortAggregate(key=[demandChannel#1036515, shardId#1011815, qty#1036535, worklistShardItemId#1011816L, demandStream#1036516], functions=[first(kpis#1036544, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1036535, demandChannel#1036515, demandStream#1036516, kpis#1036677])\n+- *(6) Sort [demandChannel#1036515 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1036535 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1036516 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1036515, shardId#1011815, qty#1036535, worklistShardItemId#1011816L, demandStream#1036516, 37), ENSURE_REQUIREMENTS, [plan_id=1680944]\n +- SortAggregate(key=[demandChannel#1036515, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1036535)) AS qty#1036535, worklistShardItemId#1011816L, demandStream#1036516], functions=[partial_first(kpis#1036544, false)], output=[demandChannel#1036515, shardId#1011815, qty#1036535, worklistShardItemId#1011816L,... [51760] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135224 { id="cluster_135224"; isCluster="true"; label="InMemoryTableScan"; 51798 [id="node_51798" labelType="html" label="MapPartitionsRDD [51798] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51799 [id="node_51799" labelType="html" label="MapPartitionsRDD [51799] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51800 [id="node_51800" labelType="html" label="MapPartitionsRDD [51800] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135220 { id="cluster_135220"; isCluster="true"; label="WholeStageCodegen (1)"; 51801 [id="node_51801" labelType="html" label="MapPartitionsRDD [51801] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135228 { id="cluster_135228"; isCluster="true"; label="InMemoryTableScan"; 51802 [id="node_51802" labelType="html" label="MapPartitionsRDD [51802] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51803 [id="node_51803" labelType="html" label="MapPartitionsRDD [51803] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51804 [id="node_51804" labelType="html" label="MapPartitionsRDD [51804] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135225 { id="cluster_135225"; isCluster="true"; label="WholeStageCodegen (2)"; 51805 [id="node_51805" labelType="html" label="MapPartitionsRDD [51805] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135219 { id="cluster_135219"; isCluster="true"; label="Union"; 51806 [id="node_51806" labelType="html" label="UnionRDD [51806] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135195 { id="cluster_135195"; isCluster="true"; label="WholeStageCodegen (5)"; 51807 [id="node_51807" labelType="html" label="MapPartitionsRDD [51807] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135194 { id="cluster_135194"; isCluster="true"; label="InMemoryTableScan"; 51808 [id="node_51808" labelType="html" label="MapPartitionsRDD [51808] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51809 [id="node_51809" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1037348, qty#1011822, demandChannel#1033979, demandStream#1033980, kpis#1034014]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1037445, worklistShardItemId#1037446L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1033979, demandStream#1033980, kpis#1034014]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1033982 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1033979, demandStream#1033980, isNewlyCalculated#1033982, kpis#1034014, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1033982, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [51809] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135253 { id="cluster_135253"; isCluster="true"; label="InMemoryTableScan"; 51818 [id="node_51818" labelType="html" label="MapPartitionsRDD [51818] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51819 [id="node_51819" labelType="html" label="MapPartitionsRDD [51819] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51820 [id="node_51820" labelType="html" label="MapPartitionsRDD [51820] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51622->51623; 51634->51635; 51638->51639; 51635->51640; 51639->51640; 51640->51641; 51641->51642; 51642->51643; 51650->51651; 51623->51652; 51651->51652; 51652->51653; 51643->51654; 51654->51655; 51655->51656; 51656->51657; 51653->51658; 51657->51658; 51658->51659; 51659->51660; 51756->51757; 51757->51758; 51758->51759; 51759->51760; 51660->51798; 51798->51799; 51799->51800; 51800->51801; 51760->51802; 51802->51803; 51803->51804; 51804->51805; 51801->51806; 51805->51806; 51806->51807; 51807->51808; 51808->51809; 51809->51818; 51818->51819; 51819->51820; }