digraph G { id="graph_114204"; subgraph graph_stage_114204 { id="graph_stage_114204"; isCluster="true"; label="Stage 114204"; subgraph cluster_141057 { id="cluster_141057"; isCluster="true"; label="Exchange"; 54286 [id="node_54286" labelType="html" label="ShuffledRowRDD [54286] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141054 { id="cluster_141054"; isCluster="true"; label="WholeStageCodegen (1)"; 54287 [id="node_54287" labelType="html" label="MapPartitionsRDD [54287] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141077 { id="cluster_141077"; isCluster="true"; label="Exchange"; 54298 [id="node_54298" labelType="html" label="ShuffledRowRDD [54298] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141074 { id="cluster_141074"; isCluster="true"; label="WholeStageCodegen (4)"; 54299 [id="node_54299" labelType="html" label="MapPartitionsRDD [54299] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141106 { id="cluster_141106"; isCluster="true"; label="Exchange"; 54302 [id="node_54302" labelType="html" label="ShuffledRowRDD [54302] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141103 { id="cluster_141103"; isCluster="true"; label="WholeStageCodegen (6)"; 54303 [id="node_54303" labelType="html" label="MapPartitionsRDD [54303] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141066 { id="cluster_141066"; isCluster="true"; label="WholeStageCodegen (7)"; 54304 [id="node_54304" labelType="html" label="ZippedPartitionsRDD2 [54304] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54305 [id="node_54305" labelType="html" label="MapPartitionsRDD [54305] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141065 { id="cluster_141065"; isCluster="true"; label="InMemoryTableScan"; 54306 [id="node_54306" labelType="html" label="MapPartitionsRDD [54306] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54307 [id="node_54307" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1089623 AS qty#1089625, demandChannel#1089618, demandStream#1089619, cachedKpis#1089624 AS kpis#1089626]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1089622L, cachedShardId#1089621], 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=1695832]\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... [54307] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141063 { id="cluster_141063"; isCluster="true"; label="Exchange"; 54314 [id="node_54314" labelType="html" label="ShuffledRowRDD [54314] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141060 { id="cluster_141060"; isCluster="true"; label="WholeStageCodegen (4)"; 54315 [id="node_54315" labelType="html" label="MapPartitionsRDD [54315] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141046 { id="cluster_141046"; isCluster="true"; label="WholeStageCodegen (5)"; 54316 [id="node_54316" labelType="html" label="ZippedPartitionsRDD2 [54316] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54317 [id="node_54317" labelType="html" label="MapPartitionsRDD [54317] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141121 { id="cluster_141121"; isCluster="true"; label="InMemoryTableScan"; 54318 [id="node_54318" labelType="html" label="MapPartitionsRDD [54318] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54319 [id="node_54319" labelType="html" label="MapPartitionsRDD [54319] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54320 [id="node_54320" labelType="html" label="MapPartitionsRDD [54320] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141118 { id="cluster_141118"; isCluster="true"; label="WholeStageCodegen (6)"; 54321 [id="node_54321" labelType="html" label="MapPartitionsRDD [54321] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141045 { id="cluster_141045"; isCluster="true"; label="Union"; 54322 [id="node_54322" labelType="html" label="UnionRDD [54322] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141044 { id="cluster_141044"; isCluster="true"; label="InMemoryTableScan"; 54323 [id="node_54323" labelType="html" label="MapPartitionsRDD [54323] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54324 [id="node_54324" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1089858, null AS demandStream#1089859, [] AS kpis#1089893, true AS isNewlyCalculated#1089861]\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#1089850, ), isnull(shardId#1089850), coalesce(worklistShardItemId#1089851L, 0), isnull(worklistShardItemId#1089851L), coalesce(version#1089852, 0), isnull(version#1089852), coalesce(product#1089853, ), isnull(product#1089853), coalesce(plant#1089854, ), isnull(plant#1089854), knownfloatingpointnormalized(normalizenanandzero(coalesce... [54324] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141334 { id="cluster_141334"; isCluster="true"; label="Exchange"; 54420 [id="node_54420" labelType="html" label="ShuffledRowRDD [54420] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141328 { id="cluster_141328"; isCluster="true"; label="WholeStageCodegen (6)"; 54421 [id="node_54421" labelType="html" label="MapPartitionsRDD [54421] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141327 { id="cluster_141327"; isCluster="true"; label="SortAggregate"; 54422 [id="node_54422" labelType="html" label="MapPartitionsRDD [54422] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141326 { id="cluster_141326"; isCluster="true"; label="InMemoryTableScan"; 54423 [id="node_54423" labelType="html" label="MapPartitionsRDD [54423] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54424 [id="node_54424" labelType="html" label="SortAggregate(key=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[first(kpis#1092423, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1092414, demandChannel#1092394, demandStream#1092395, kpis#1092556])\n+- *(6) Sort [demandChannel#1092394 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1092414 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1092395 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395, 37), ENSURE_REQUIREMENTS, [plan_id=1696762]\n +- SortAggregate(key=[demandChannel#1092394, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1092414)) AS qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[partial_first(kpis#1092423, false)], output=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L,... [54424] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141493 { id="cluster_141493"; isCluster="true"; label="InMemoryTableScan"; 54462 [id="node_54462" labelType="html" label="MapPartitionsRDD [54462] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54463 [id="node_54463" labelType="html" label="MapPartitionsRDD [54463] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54464 [id="node_54464" labelType="html" label="MapPartitionsRDD [54464] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141489 { id="cluster_141489"; isCluster="true"; label="WholeStageCodegen (1)"; 54465 [id="node_54465" labelType="html" label="MapPartitionsRDD [54465] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141497 { id="cluster_141497"; isCluster="true"; label="InMemoryTableScan"; 54466 [id="node_54466" labelType="html" label="MapPartitionsRDD [54466] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54467 [id="node_54467" labelType="html" label="MapPartitionsRDD [54467] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54468 [id="node_54468" labelType="html" label="MapPartitionsRDD [54468] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141494 { id="cluster_141494"; isCluster="true"; label="WholeStageCodegen (2)"; 54469 [id="node_54469" labelType="html" label="MapPartitionsRDD [54469] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141488 { id="cluster_141488"; isCluster="true"; label="Union"; 54470 [id="node_54470" labelType="html" label="UnionRDD [54470] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141464 { id="cluster_141464"; isCluster="true"; label="WholeStageCodegen (5)"; 54471 [id="node_54471" labelType="html" label="MapPartitionsRDD [54471] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141463 { id="cluster_141463"; isCluster="true"; label="InMemoryTableScan"; 54472 [id="node_54472" labelType="html" label="MapPartitionsRDD [54472] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54473 [id="node_54473" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1093227, qty#1011822, demandChannel#1089858, demandStream#1089859, kpis#1089893]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1093324, worklistShardItemId#1093325L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1089858, demandStream#1089859, kpis#1089893]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1089861 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1089858, demandStream#1089859, isNewlyCalculated#1089861, kpis#1089893, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1089861, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [54473] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141522 { id="cluster_141522"; isCluster="true"; label="InMemoryTableScan"; 54482 [id="node_54482" labelType="html" label="MapPartitionsRDD [54482] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54483 [id="node_54483" labelType="html" label="MapPartitionsRDD [54483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54484 [id="node_54484" labelType="html" label="MapPartitionsRDD [54484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54286->54287; 54298->54299; 54302->54303; 54299->54304; 54303->54304; 54304->54305; 54305->54306; 54306->54307; 54314->54315; 54287->54316; 54315->54316; 54316->54317; 54307->54318; 54318->54319; 54319->54320; 54320->54321; 54317->54322; 54321->54322; 54322->54323; 54323->54324; 54420->54421; 54421->54422; 54422->54423; 54423->54424; 54324->54462; 54462->54463; 54463->54464; 54464->54465; 54424->54466; 54466->54467; 54467->54468; 54468->54469; 54465->54470; 54469->54470; 54470->54471; 54471->54472; 54472->54473; 54473->54482; 54482->54483; 54483->54484; }