digraph G { id="graph_917"; subgraph graph_stage_917 { id="graph_stage_917"; isCluster="true"; label="Stage 917"; subgraph cluster_3249 { id="cluster_3249"; isCluster="true"; label="Exchange"; 1194 [id="node_1194" labelType="html" label="ShuffledRowRDD [1194] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3246 { id="cluster_3246"; isCluster="true"; label="WholeStageCodegen (1)"; 1195 [id="node_1195" labelType="html" label="MapPartitionsRDD [1195] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3274 { id="cluster_3274"; isCluster="true"; label="Exchange"; 1201 [id="node_1201" labelType="html" label="ShuffledRowRDD [1201] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3271 { id="cluster_3271"; isCluster="true"; label="WholeStageCodegen (2)"; 1202 [id="node_1202" labelType="html" label="MapPartitionsRDD [1202] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3283 { id="cluster_3283"; isCluster="true"; label="Exchange"; 1205 [id="node_1205" labelType="html" label="ShuffledRowRDD [1205] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3280 { id="cluster_3280"; isCluster="true"; label="WholeStageCodegen (4)"; 1208 [id="node_1208" labelType="html" label="MapPartitionsRDD [1208] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3262 { id="cluster_3262"; isCluster="true"; label="WholeStageCodegen (5)"; 1212 [id="node_1212" labelType="html" label="ZippedPartitionsRDD2 [1212] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1215 [id="node_1215" labelType="html" label="MapPartitionsRDD [1215] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3292 { id="cluster_3292"; isCluster="true"; label="Exchange"; 1218 [id="node_1218" labelType="html" label="ShuffledRowRDD [1218] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3289 { id="cluster_3289"; isCluster="true"; label="WholeStageCodegen (7)"; 1219 [id="node_1219" labelType="html" label="MapPartitionsRDD [1219] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3258 { id="cluster_3258"; isCluster="true"; label="WholeStageCodegen (8)"; 1220 [id="node_1220" labelType="html" label="ZippedPartitionsRDD2 [1220] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1221 [id="node_1221" labelType="html" label="MapPartitionsRDD [1221] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3257 { id="cluster_3257"; isCluster="true"; label="InMemoryTableScan"; 1222 [id="node_1222" labelType="html" label="MapPartitionsRDD [1222] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1223 [id="node_1223" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#18776 AS qty#18778, demandChannel#18771, demandStream#18772, cachedKpis#18777 AS kpis#18779]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#18775L, cachedShardId#18774], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1223] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3255 { id="cluster_3255"; isCluster="true"; label="Exchange"; 1242 [id="node_1242" labelType="html" label="ShuffledRowRDD [1242] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3252 { id="cluster_3252"; isCluster="true"; label="WholeStageCodegen (7)"; 1245 [id="node_1245" labelType="html" label="MapPartitionsRDD [1245] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3238 { id="cluster_3238"; isCluster="true"; label="WholeStageCodegen (8)"; 1246 [id="node_1246" labelType="html" label="ZippedPartitionsRDD2 [1246] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1247 [id="node_1247" labelType="html" label="MapPartitionsRDD [1247] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3325 { id="cluster_3325"; isCluster="true"; label="InMemoryTableScan"; 1248 [id="node_1248" labelType="html" label="MapPartitionsRDD [1248] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1249 [id="node_1249" labelType="html" label="MapPartitionsRDD [1249] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1250 [id="node_1250" labelType="html" label="MapPartitionsRDD [1250] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3322 { id="cluster_3322"; isCluster="true"; label="WholeStageCodegen (9)"; 1251 [id="node_1251" labelType="html" label="MapPartitionsRDD [1251] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3237 { id="cluster_3237"; isCluster="true"; label="Union"; 1252 [id="node_1252" labelType="html" label="UnionRDD [1252] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3236 { id="cluster_3236"; isCluster="true"; label="InMemoryTableScan"; 1253 [id="node_1253" labelType="html" label="MapPartitionsRDD [1253] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1254 [id="node_1254" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#19011, null AS demandStream#19012, [] AS kpis#19046, true AS isNewlyCalculated#19014]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#19003, ), isnull(shardId#19003), coalesce(worklistShardItemId#19004L, 0), isnull(worklistShardItemId#19004L), coalesce(version#19005, 0), isnull(version#19005), coalesce(product#19006, ), isnull(product#19006), coalesce(plant#19007, ), isnull(plant#19007), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#18778, 0.0))), isnull(qty#18778)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1254] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3552 { id="cluster_3552"; isCluster="true"; label="Exchange"; 1356 [id="node_1356" labelType="html" label="ShuffledRowRDD [1356] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3549 { id="cluster_3549"; isCluster="true"; label="WholeStageCodegen (8)"; 1357 [id="node_1357" labelType="html" label="MapPartitionsRDD [1357] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3548 { id="cluster_3548"; isCluster="true"; label="SortAggregate"; 1358 [id="node_1358" labelType="html" label="MapPartitionsRDD [1358] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3547 { id="cluster_3547"; isCluster="true"; label="InMemoryTableScan"; 1359 [id="node_1359" labelType="html" label="MapPartitionsRDD [1359] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1360 [id="node_1360" labelType="html" label="SortAggregate(key=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[first(kpis#21616, false)], output=[shardId#445, worklistShardItemId#446L, qty#21607, demandChannel#21587, demandStream#21588, kpis#21749])\n+- *(8) Sort [demandChannel#21587 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#21607 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#21588 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, 37), ENSURE_REQUIREMENTS, [plan_id=116966]\n +- SortAggregate(key=[demandChannel#21587, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#21607)) AS qty#21607, worklistShardItemId#446L, demandStream#21588], functions=[partial_first(kpis#21616, false)], output=[demandChannel#21587, shardId#445, qty#21607, worklistShardItemId#446L, demandStream#21588, first#21825, valueSet#21826])\n +- *(7) Sort [demandChannel#215... [1360] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3712 { id="cluster_3712"; isCluster="true"; label="InMemoryTableScan"; 1390 [id="node_1390" labelType="html" label="MapPartitionsRDD [1390] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1391 [id="node_1391" labelType="html" label="MapPartitionsRDD [1391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1392 [id="node_1392" labelType="html" label="MapPartitionsRDD [1392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3708 { id="cluster_3708"; isCluster="true"; label="WholeStageCodegen (1)"; 1393 [id="node_1393" labelType="html" label="MapPartitionsRDD [1393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3716 { id="cluster_3716"; isCluster="true"; label="InMemoryTableScan"; 1394 [id="node_1394" labelType="html" label="MapPartitionsRDD [1394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1395 [id="node_1395" labelType="html" label="MapPartitionsRDD [1395] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1396 [id="node_1396" labelType="html" label="MapPartitionsRDD [1396] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3713 { id="cluster_3713"; isCluster="true"; label="WholeStageCodegen (2)"; 1397 [id="node_1397" labelType="html" label="MapPartitionsRDD [1397] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3707 { id="cluster_3707"; isCluster="true"; label="Union"; 1398 [id="node_1398" labelType="html" label="UnionRDD [1398] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3706 { id="cluster_3706"; isCluster="true"; label="Exchange"; 1399 [id="node_1399" labelType="html" label="MapPartitionsRDD [1399] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 1194->1195; 1201->1202; 1205->1208; 1202->1212; 1208->1212; 1212->1215; 1218->1219; 1215->1220; 1219->1220; 1220->1221; 1221->1222; 1222->1223; 1242->1245; 1195->1246; 1245->1246; 1246->1247; 1223->1248; 1248->1249; 1249->1250; 1250->1251; 1247->1252; 1251->1252; 1252->1253; 1253->1254; 1356->1357; 1357->1358; 1358->1359; 1359->1360; 1254->1390; 1390->1391; 1391->1392; 1392->1393; 1360->1394; 1394->1395; 1395->1396; 1396->1397; 1393->1398; 1397->1398; 1398->1399; }