digraph G { id="graph_100654"; subgraph graph_stage_100654 { id="graph_stage_100654"; isCluster="true"; label="Stage 100654"; subgraph cluster_121080 { id="cluster_121080"; isCluster="true"; label="Exchange"; 46645 [id="node_46645" labelType="html" label="ShuffledRowRDD [46645] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121077 { id="cluster_121077"; isCluster="true"; label="WholeStageCodegen (1)"; 46646 [id="node_46646" labelType="html" label="MapPartitionsRDD [46646] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121100 { id="cluster_121100"; isCluster="true"; label="Exchange"; 46657 [id="node_46657" labelType="html" label="ShuffledRowRDD [46657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121097 { id="cluster_121097"; isCluster="true"; label="WholeStageCodegen (4)"; 46658 [id="node_46658" labelType="html" label="MapPartitionsRDD [46658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121129 { id="cluster_121129"; isCluster="true"; label="Exchange"; 46661 [id="node_46661" labelType="html" label="ShuffledRowRDD [46661] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121126 { id="cluster_121126"; isCluster="true"; label="WholeStageCodegen (6)"; 46662 [id="node_46662" labelType="html" label="MapPartitionsRDD [46662] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121089 { id="cluster_121089"; isCluster="true"; label="WholeStageCodegen (7)"; 46663 [id="node_46663" labelType="html" label="ZippedPartitionsRDD2 [46663] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46664 [id="node_46664" labelType="html" label="MapPartitionsRDD [46664] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121088 { id="cluster_121088"; isCluster="true"; label="InMemoryTableScan"; 46665 [id="node_46665" labelType="html" label="MapPartitionsRDD [46665] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46666 [id="node_46666" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#938355 AS qty#938357, demandChannel#938350, demandStream#938351, cachedKpis#938356 AS kpis#938358]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#938354L, cachedShardId#938353], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1454068]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1454064]\n : +- *(2) Has... [46666] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121086 { id="cluster_121086"; isCluster="true"; label="Exchange"; 46673 [id="node_46673" labelType="html" label="ShuffledRowRDD [46673] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121083 { id="cluster_121083"; isCluster="true"; label="WholeStageCodegen (4)"; 46674 [id="node_46674" labelType="html" label="MapPartitionsRDD [46674] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121069 { id="cluster_121069"; isCluster="true"; label="WholeStageCodegen (5)"; 46675 [id="node_46675" labelType="html" label="ZippedPartitionsRDD2 [46675] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46676 [id="node_46676" labelType="html" label="MapPartitionsRDD [46676] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121144 { id="cluster_121144"; isCluster="true"; label="InMemoryTableScan"; 46677 [id="node_46677" labelType="html" label="MapPartitionsRDD [46677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46678 [id="node_46678" labelType="html" label="MapPartitionsRDD [46678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46679 [id="node_46679" labelType="html" label="MapPartitionsRDD [46679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121141 { id="cluster_121141"; isCluster="true"; label="WholeStageCodegen (6)"; 46680 [id="node_46680" labelType="html" label="MapPartitionsRDD [46680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121068 { id="cluster_121068"; isCluster="true"; label="Union"; 46681 [id="node_46681" labelType="html" label="UnionRDD [46681] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121067 { id="cluster_121067"; isCluster="true"; label="InMemoryTableScan"; 46682 [id="node_46682" labelType="html" label="MapPartitionsRDD [46682] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46683 [id="node_46683" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#938590, null AS demandStream#938591, [] AS kpis#938625, true AS isNewlyCalculated#938593]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#938582, ), isnull(shardId#938582), coalesce(worklistShardItemId#938583L, 0), isnull(worklistShardItemId#938583L), coalesce(version#938584, 0), isnull(version#938584), coalesce(product#938585, ), isnull(product#938585), coalesce(plant#938586, ), isnull(plant#938586), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#938357, 0.0))), isnull(qty#... [46683] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121356 { id="cluster_121356"; isCluster="true"; label="Exchange"; 46779 [id="node_46779" labelType="html" label="ShuffledRowRDD [46779] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121351 { id="cluster_121351"; isCluster="true"; label="WholeStageCodegen (6)"; 46780 [id="node_46780" labelType="html" label="MapPartitionsRDD [46780] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121350 { id="cluster_121350"; isCluster="true"; label="SortAggregate"; 46781 [id="node_46781" labelType="html" label="MapPartitionsRDD [46781] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121349 { id="cluster_121349"; isCluster="true"; label="InMemoryTableScan"; 46782 [id="node_46782" labelType="html" label="MapPartitionsRDD [46782] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46783 [id="node_46783" labelType="html" label="SortAggregate(key=[demandChannel#941126, shardId#904714, qty#941146, worklistShardItemId#904715L, demandStream#941127], functions=[first(kpis#941155, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#941146, demandChannel#941126, demandStream#941127, kpis#941288])\n+- *(6) Sort [demandChannel#941126 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#941146 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#941127 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#941126, shardId#904714, qty#941146, worklistShardItemId#904715L, demandStream#941127, 37), ENSURE_REQUIREMENTS, [plan_id=1454998]\n +- SortAggregate(key=[demandChannel#941126, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#941146)) AS qty#941146, worklistShardItemId#904715L, demandStream#941127], functions=[partial_first(kpis#941155, false)], output=[demandChannel#941126, shardId#904714, qty#941146, worklistShardItemId#904715L, demandStream#941127, first#94136... [46783] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121516 { id="cluster_121516"; isCluster="true"; label="InMemoryTableScan"; 46821 [id="node_46821" labelType="html" label="MapPartitionsRDD [46821] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46822 [id="node_46822" labelType="html" label="MapPartitionsRDD [46822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46823 [id="node_46823" labelType="html" label="MapPartitionsRDD [46823] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121512 { id="cluster_121512"; isCluster="true"; label="WholeStageCodegen (1)"; 46824 [id="node_46824" labelType="html" label="MapPartitionsRDD [46824] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121520 { id="cluster_121520"; isCluster="true"; label="InMemoryTableScan"; 46825 [id="node_46825" labelType="html" label="MapPartitionsRDD [46825] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46826 [id="node_46826" labelType="html" label="MapPartitionsRDD [46826] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46827 [id="node_46827" labelType="html" label="MapPartitionsRDD [46827] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121517 { id="cluster_121517"; isCluster="true"; label="WholeStageCodegen (2)"; 46828 [id="node_46828" labelType="html" label="MapPartitionsRDD [46828] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121511 { id="cluster_121511"; isCluster="true"; label="Union"; 46829 [id="node_46829" labelType="html" label="UnionRDD [46829] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121487 { id="cluster_121487"; isCluster="true"; label="WholeStageCodegen (5)"; 46830 [id="node_46830" labelType="html" label="MapPartitionsRDD [46830] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121486 { id="cluster_121486"; isCluster="true"; label="InMemoryTableScan"; 46831 [id="node_46831" labelType="html" label="MapPartitionsRDD [46831] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46832 [id="node_46832" labelType="html" label="*(5) Project [shardId#904714, worklistShardItemId#904715L, version#941959, qty#904721, demandChannel#938590, demandStream#938591, kpis#938625]\n+- *(5) BroadcastHashJoin [shardId#904714, worklistShardItemId#904715L], [shardId#942056, worklistShardItemId#942057L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#904714, worklistShardItemId#904715L, qty#904721, demandChannel#938590, demandStream#938591, kpis#938625]\n : : +- *(1) Filter ((NOT isNewlyCalculated#938593 AND isnotnull(shardId#904714)) AND isnotnull(worklistShardItemId#904715L))\n : : +- InMemoryTableScan [demandChannel#938590, demandStream#938591, isNewlyCalculated#938593, kpis#938625, qty#904721, shardId#904714, worklistShardItemId#904715L], [NOT isNewlyCalculated#938593, isnotnull(shardId#904714), isnotnull(worklistShardItemId#904715L)]\n : : +- InMemoryRelation [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, demandChannel#938590, demandStream#938591... [46832] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46833 [id="node_46833" labelType="html" label="MapPartitionsRDD [46833] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46834 [id="node_46834" labelType="html" label="MapPartitionsRDD [46834] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46835 [id="node_46835" labelType="html" label="MapPartitionsRDD [46835] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121485 { id="cluster_121485"; isCluster="true"; label="CollectLimit"; 46836 [id="node_46836" labelType="html" label="MapPartitionsRDD [46836] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46837 [id="node_46837" labelType="html" label="MapPartitionsRDD [46837] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46645->46646; 46657->46658; 46661->46662; 46658->46663; 46662->46663; 46663->46664; 46664->46665; 46665->46666; 46673->46674; 46646->46675; 46674->46675; 46675->46676; 46666->46677; 46677->46678; 46678->46679; 46679->46680; 46676->46681; 46680->46681; 46681->46682; 46682->46683; 46779->46780; 46780->46781; 46781->46782; 46782->46783; 46683->46821; 46821->46822; 46822->46823; 46823->46824; 46783->46825; 46825->46826; 46826->46827; 46827->46828; 46824->46829; 46828->46829; 46829->46830; 46830->46831; 46831->46832; 46832->46833; 46833->46834; 46834->46835; 46835->46836; 46836->46837; }