digraph G { id="graph_118866"; subgraph graph_stage_118866 { id="graph_stage_118866"; isCluster="true"; label="Stage 118866"; subgraph cluster_149137 { id="cluster_149137"; isCluster="true"; label="Exchange"; 57521 [id="node_57521" labelType="html" label="ShuffledRowRDD [57521] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149134 { id="cluster_149134"; isCluster="true"; label="WholeStageCodegen (1)"; 57522 [id="node_57522" labelType="html" label="MapPartitionsRDD [57522] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149157 { id="cluster_149157"; isCluster="true"; label="Exchange"; 57533 [id="node_57533" labelType="html" label="ShuffledRowRDD [57533] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149154 { id="cluster_149154"; isCluster="true"; label="WholeStageCodegen (4)"; 57534 [id="node_57534" labelType="html" label="MapPartitionsRDD [57534] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149186 { id="cluster_149186"; isCluster="true"; label="Exchange"; 57537 [id="node_57537" labelType="html" label="ShuffledRowRDD [57537] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149183 { id="cluster_149183"; isCluster="true"; label="WholeStageCodegen (6)"; 57538 [id="node_57538" labelType="html" label="MapPartitionsRDD [57538] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149146 { id="cluster_149146"; isCluster="true"; label="WholeStageCodegen (7)"; 57539 [id="node_57539" labelType="html" label="ZippedPartitionsRDD2 [57539] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57540 [id="node_57540" labelType="html" label="MapPartitionsRDD [57540] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149145 { id="cluster_149145"; isCluster="true"; label="InMemoryTableScan"; 57541 [id="node_57541" labelType="html" label="MapPartitionsRDD [57541] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57542 [id="node_57542" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1156234 AS qty#1156236, demandChannel#1156229, demandStream#1156230, cachedKpis#1156235 AS kpis#1156237]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1156233L, cachedShardId#1156232], 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=1763276]\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... [57542] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149143 { id="cluster_149143"; isCluster="true"; label="Exchange"; 57549 [id="node_57549" labelType="html" label="ShuffledRowRDD [57549] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149140 { id="cluster_149140"; isCluster="true"; label="WholeStageCodegen (4)"; 57550 [id="node_57550" labelType="html" label="MapPartitionsRDD [57550] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149126 { id="cluster_149126"; isCluster="true"; label="WholeStageCodegen (5)"; 57551 [id="node_57551" labelType="html" label="ZippedPartitionsRDD2 [57551] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57552 [id="node_57552" labelType="html" label="MapPartitionsRDD [57552] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149207 { id="cluster_149207"; isCluster="true"; label="InMemoryTableScan"; 57553 [id="node_57553" labelType="html" label="MapPartitionsRDD [57553] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57554 [id="node_57554" labelType="html" label="MapPartitionsRDD [57554] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57555 [id="node_57555" labelType="html" label="MapPartitionsRDD [57555] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149204 { id="cluster_149204"; isCluster="true"; label="WholeStageCodegen (6)"; 57556 [id="node_57556" labelType="html" label="MapPartitionsRDD [57556] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149125 { id="cluster_149125"; isCluster="true"; label="Union"; 57557 [id="node_57557" labelType="html" label="UnionRDD [57557] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149124 { id="cluster_149124"; isCluster="true"; label="InMemoryTableScan"; 57558 [id="node_57558" labelType="html" label="MapPartitionsRDD [57558] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57559 [id="node_57559" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1156469, null AS demandStream#1156470, [] AS kpis#1156504, true AS isNewlyCalculated#1156472]\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#1156461, ), isnull(shardId#1156461), coalesce(worklistShardItemId#1156462L, 0), isnull(worklistShardItemId#1156462L), coalesce(version#1156463, 0), isnull(version#1156463), coalesce(product#1156464, ), isnull(product#1156464), coalesce(plant#1156465, ), isnull(plant#1156465), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57559] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149428 { id="cluster_149428"; isCluster="true"; label="InMemoryTableScan"; 57625 [id="node_57625" labelType="html" label="MapPartitionsRDD [57625] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57626 [id="node_57626" labelType="html" label="MapPartitionsRDD [57626] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57627 [id="node_57627" labelType="html" label="MapPartitionsRDD [57627] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149423 { id="cluster_149423"; isCluster="true"; label="WholeStageCodegen (3)"; 57628 [id="node_57628" labelType="html" label="MapPartitionsRDD [57628] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149422 { id="cluster_149422"; isCluster="true"; label="Exchange"; 57629 [id="node_57629" labelType="html" label="MapPartitionsRDD [57629] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57521->57522; 57533->57534; 57537->57538; 57534->57539; 57538->57539; 57539->57540; 57540->57541; 57541->57542; 57549->57550; 57522->57551; 57550->57551; 57551->57552; 57542->57553; 57553->57554; 57554->57555; 57555->57556; 57552->57557; 57556->57557; 57557->57558; 57558->57559; 57559->57625; 57625->57626; 57626->57627; 57627->57628; 57628->57629; }