digraph G { id="graph_118102"; subgraph graph_stage_118102 { id="graph_stage_118102"; isCluster="true"; label="Stage 118102"; subgraph cluster_148516 { id="cluster_148516"; isCluster="true"; label="Exchange"; 57257 [id="node_57257" labelType="html" label="ShuffledRowRDD [57257] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148513 { id="cluster_148513"; isCluster="true"; label="WholeStageCodegen (1)"; 57258 [id="node_57258" labelType="html" label="MapPartitionsRDD [57258] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148536 { id="cluster_148536"; isCluster="true"; label="Exchange"; 57269 [id="node_57269" labelType="html" label="ShuffledRowRDD [57269] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148533 { id="cluster_148533"; isCluster="true"; label="WholeStageCodegen (4)"; 57270 [id="node_57270" labelType="html" label="MapPartitionsRDD [57270] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148565 { id="cluster_148565"; isCluster="true"; label="Exchange"; 57273 [id="node_57273" labelType="html" label="ShuffledRowRDD [57273] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148562 { id="cluster_148562"; isCluster="true"; label="WholeStageCodegen (6)"; 57274 [id="node_57274" labelType="html" label="MapPartitionsRDD [57274] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148525 { id="cluster_148525"; isCluster="true"; label="WholeStageCodegen (7)"; 57275 [id="node_57275" labelType="html" label="ZippedPartitionsRDD2 [57275] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57276 [id="node_57276" labelType="html" label="MapPartitionsRDD [57276] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148524 { id="cluster_148524"; isCluster="true"; label="InMemoryTableScan"; 57277 [id="node_57277" labelType="html" label="MapPartitionsRDD [57277] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57278 [id="node_57278" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1150676 AS qty#1150678, demandChannel#1150671, demandStream#1150672, cachedKpis#1150677 AS kpis#1150679]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1150675L, cachedShardId#1150674], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1761686]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [57278] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148522 { id="cluster_148522"; isCluster="true"; label="Exchange"; 57285 [id="node_57285" labelType="html" label="ShuffledRowRDD [57285] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148519 { id="cluster_148519"; isCluster="true"; label="WholeStageCodegen (4)"; 57286 [id="node_57286" labelType="html" label="MapPartitionsRDD [57286] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148505 { id="cluster_148505"; isCluster="true"; label="WholeStageCodegen (5)"; 57287 [id="node_57287" labelType="html" label="ZippedPartitionsRDD2 [57287] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57288 [id="node_57288" labelType="html" label="MapPartitionsRDD [57288] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148580 { id="cluster_148580"; isCluster="true"; label="InMemoryTableScan"; 57289 [id="node_57289" labelType="html" label="MapPartitionsRDD [57289] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57290 [id="node_57290" labelType="html" label="MapPartitionsRDD [57290] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57291 [id="node_57291" labelType="html" label="MapPartitionsRDD [57291] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148577 { id="cluster_148577"; isCluster="true"; label="WholeStageCodegen (6)"; 57292 [id="node_57292" labelType="html" label="MapPartitionsRDD [57292] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148504 { id="cluster_148504"; isCluster="true"; label="Union"; 57293 [id="node_57293" labelType="html" label="UnionRDD [57293] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148503 { id="cluster_148503"; isCluster="true"; label="InMemoryTableScan"; 57294 [id="node_57294" labelType="html" label="MapPartitionsRDD [57294] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57295 [id="node_57295" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1150911, null AS demandStream#1150912, [] AS kpis#1150946, true AS isNewlyCalculated#1150914]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1150903, ), isnull(shardId#1150903), coalesce(worklistShardItemId#1150904L, 0), isnull(worklistShardItemId#1150904L), coalesce(version#1150905, 0), isnull(version#1150905), coalesce(product#1150906, ), isnull(product#1150906), coalesce(plant#1150907, ), isnull(plant#1150907), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57295] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148720 { id="cluster_148720"; isCluster="true"; label="InMemoryTableScan"; 57334 [id="node_57334" labelType="html" label="MapPartitionsRDD [57334] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57335 [id="node_57335" labelType="html" label="MapPartitionsRDD [57335] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57336 [id="node_57336" labelType="html" label="MapPartitionsRDD [57336] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148716 { id="cluster_148716"; isCluster="true"; label="WholeStageCodegen (11)"; 57337 [id="node_57337" labelType="html" label="MapPartitionsRDD [57337] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148715 { id="cluster_148715"; isCluster="true"; label="ObjectHashAggregate"; 57338 [id="node_57338" labelType="html" label="MapPartitionsRDD [57338] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148714 { id="cluster_148714"; isCluster="true"; label="Exchange"; 57339 [id="node_57339" labelType="html" label="MapPartitionsRDD [57339] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57257->57258; 57269->57270; 57273->57274; 57270->57275; 57274->57275; 57275->57276; 57276->57277; 57277->57278; 57285->57286; 57258->57287; 57286->57287; 57287->57288; 57278->57289; 57289->57290; 57290->57291; 57291->57292; 57288->57293; 57292->57293; 57293->57294; 57294->57295; 57295->57334; 57334->57335; 57335->57336; 57336->57337; 57337->57338; 57338->57339; }