digraph G { id="graph_710"; subgraph graph_stage_710 { id="graph_stage_710"; isCluster="true"; label="Stage 710"; 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}"]; 1255 [id="node_1255" labelType="html" label="MapPartitionsRDD [1255] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1256 [id="node_1256" labelType="html" label="MapPartitionsRDD [1256] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1257 [id="node_1257" labelType="html" label="MapPartitionsRDD [1257] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3230 { id="cluster_3230"; isCluster="true"; label="WholeStageCodegen (14)"; 1258 [id="node_1258" labelType="html" label="MapPartitionsRDD [1258] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3228 { id="cluster_3228"; isCluster="true"; label="Exchange"; 1259 [id="node_1259" labelType="html" label="MapPartitionsRDD [1259] [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; 1254->1255; 1255->1256; 1256->1257; 1257->1258; 1258->1259; }