digraph G { id="graph_118594"; subgraph graph_stage_118594 { id="graph_stage_118594"; isCluster="true"; label="Stage 118594"; 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_148792 { id="cluster_148792"; isCluster="true"; label="Exchange"; 57391 [id="node_57391" labelType="html" label="ShuffledRowRDD [57391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148787 { id="cluster_148787"; isCluster="true"; label="WholeStageCodegen (6)"; 57392 [id="node_57392" labelType="html" label="MapPartitionsRDD [57392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148786 { id="cluster_148786"; isCluster="true"; label="SortAggregate"; 57393 [id="node_57393" labelType="html" label="MapPartitionsRDD [57393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148785 { id="cluster_148785"; isCluster="true"; label="InMemoryTableScan"; 57394 [id="node_57394" labelType="html" label="MapPartitionsRDD [57394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57395 [id="node_57395" labelType="html" label="SortAggregate(key=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[first(kpis#1153476, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1153467, demandChannel#1153447, demandStream#1153448, kpis#1153609])\n+- *(6) Sort [demandChannel#1153447 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1153467 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1153448 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448, 37), ENSURE_REQUIREMENTS, [plan_id=1762616]\n +- SortAggregate(key=[demandChannel#1153447, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1153467)) AS qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[partial_first(kpis#1153476, false)], output=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L,... [57395] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148952 { id="cluster_148952"; isCluster="true"; label="InMemoryTableScan"; 57433 [id="node_57433" labelType="html" label="MapPartitionsRDD [57433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57434 [id="node_57434" labelType="html" label="MapPartitionsRDD [57434] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57435 [id="node_57435" labelType="html" label="MapPartitionsRDD [57435] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148948 { id="cluster_148948"; isCluster="true"; label="WholeStageCodegen (1)"; 57436 [id="node_57436" labelType="html" label="MapPartitionsRDD [57436] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148956 { id="cluster_148956"; isCluster="true"; label="InMemoryTableScan"; 57437 [id="node_57437" labelType="html" label="MapPartitionsRDD [57437] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57438 [id="node_57438" labelType="html" label="MapPartitionsRDD [57438] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57439 [id="node_57439" labelType="html" label="MapPartitionsRDD [57439] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148953 { id="cluster_148953"; isCluster="true"; label="WholeStageCodegen (2)"; 57440 [id="node_57440" labelType="html" label="MapPartitionsRDD [57440] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148947 { id="cluster_148947"; isCluster="true"; label="Union"; 57441 [id="node_57441" labelType="html" label="UnionRDD [57441] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148923 { id="cluster_148923"; isCluster="true"; label="WholeStageCodegen (5)"; 57442 [id="node_57442" labelType="html" label="MapPartitionsRDD [57442] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148922 { id="cluster_148922"; isCluster="true"; label="InMemoryTableScan"; 57443 [id="node_57443" labelType="html" label="MapPartitionsRDD [57443] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57444 [id="node_57444" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1154280, qty#1100464, demandChannel#1150911, demandStream#1150912, kpis#1150946]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1154377, worklistShardItemId#1154378L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1150911, demandStream#1150912, kpis#1150946]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1150914 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1150911, demandStream#1150912, isNewlyCalculated#1150914, kpis#1150946, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1150914, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [57444] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148981 { id="cluster_148981"; isCluster="true"; label="InMemoryTableScan"; 57453 [id="node_57453" labelType="html" label="MapPartitionsRDD [57453] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57454 [id="node_57454" labelType="html" label="MapPartitionsRDD [57454] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57455 [id="node_57455" labelType="html" label="MapPartitionsRDD [57455] [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; 57391->57392; 57392->57393; 57393->57394; 57394->57395; 57295->57433; 57433->57434; 57434->57435; 57435->57436; 57395->57437; 57437->57438; 57438->57439; 57439->57440; 57436->57441; 57440->57441; 57441->57442; 57442->57443; 57443->57444; 57444->57453; 57453->57454; 57454->57455; }