digraph G { id="graph_118696"; subgraph graph_stage_118696 { id="graph_stage_118696"; isCluster="true"; label="Stage 118696"; 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}"]; 57560 [id="node_57560" labelType="html" label="MapPartitionsRDD [57560] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57561 [id="node_57561" labelType="html" label="MapPartitionsRDD [57561] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57562 [id="node_57562" labelType="html" label="MapPartitionsRDD [57562] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149119 { id="cluster_149119"; isCluster="true"; label="WholeStageCodegen (15)"; 57563 [id="node_57563" labelType="html" label="MapPartitionsRDD [57563] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149118 { id="cluster_149118"; isCluster="true"; label="Exchange"; 57564 [id="node_57564" labelType="html" label="MapPartitionsRDD [57564] [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->57560; 57560->57561; 57561->57562; 57562->57563; 57563->57564; }