digraph G { id="graph_116572"; subgraph graph_stage_116572 { id="graph_stage_116572"; isCluster="true"; label="Stage 116572"; subgraph cluster_146030 { id="cluster_146030"; isCluster="true"; label="Exchange"; 56199 [id="node_56199" labelType="html" label="ShuffledRowRDD [56199] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146027 { id="cluster_146027"; isCluster="true"; label="WholeStageCodegen (1)"; 56200 [id="node_56200" labelType="html" label="MapPartitionsRDD [56200] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146050 { id="cluster_146050"; isCluster="true"; label="Exchange"; 56211 [id="node_56211" labelType="html" label="ShuffledRowRDD [56211] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146047 { id="cluster_146047"; isCluster="true"; label="WholeStageCodegen (4)"; 56212 [id="node_56212" labelType="html" label="MapPartitionsRDD [56212] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146085 { id="cluster_146085"; isCluster="true"; label="Exchange"; 56215 [id="node_56215" labelType="html" label="ShuffledRowRDD [56215] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146082 { id="cluster_146082"; isCluster="true"; label="WholeStageCodegen (6)"; 56216 [id="node_56216" labelType="html" label="MapPartitionsRDD [56216] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146039 { id="cluster_146039"; isCluster="true"; label="WholeStageCodegen (7)"; 56217 [id="node_56217" labelType="html" label="ZippedPartitionsRDD2 [56217] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56218 [id="node_56218" labelType="html" label="MapPartitionsRDD [56218] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146038 { id="cluster_146038"; isCluster="true"; label="InMemoryTableScan"; 56219 [id="node_56219" labelType="html" label="MapPartitionsRDD [56219] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56220 [id="node_56220" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1128444 AS qty#1128446, demandChannel#1128439, demandStream#1128440, cachedKpis#1128445 AS kpis#1128447]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1128443L, cachedShardId#1128442], 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=1755382]\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... [56220] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146036 { id="cluster_146036"; isCluster="true"; label="Exchange"; 56227 [id="node_56227" labelType="html" label="ShuffledRowRDD [56227] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146033 { id="cluster_146033"; isCluster="true"; label="WholeStageCodegen (4)"; 56228 [id="node_56228" labelType="html" label="MapPartitionsRDD [56228] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146019 { id="cluster_146019"; isCluster="true"; label="WholeStageCodegen (5)"; 56229 [id="node_56229" labelType="html" label="ZippedPartitionsRDD2 [56229] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56230 [id="node_56230" labelType="html" label="MapPartitionsRDD [56230] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146100 { id="cluster_146100"; isCluster="true"; label="InMemoryTableScan"; 56231 [id="node_56231" labelType="html" label="MapPartitionsRDD [56231] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56232 [id="node_56232" labelType="html" label="MapPartitionsRDD [56232] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56233 [id="node_56233" labelType="html" label="MapPartitionsRDD [56233] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146097 { id="cluster_146097"; isCluster="true"; label="WholeStageCodegen (6)"; 56234 [id="node_56234" labelType="html" label="MapPartitionsRDD [56234] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146018 { id="cluster_146018"; isCluster="true"; label="Union"; 56235 [id="node_56235" labelType="html" label="UnionRDD [56235] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146017 { id="cluster_146017"; isCluster="true"; label="InMemoryTableScan"; 56236 [id="node_56236" labelType="html" label="MapPartitionsRDD [56236] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56237 [id="node_56237" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1128679, null AS demandStream#1128680, [] AS kpis#1128714, true AS isNewlyCalculated#1128682]\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#1128671, ), isnull(shardId#1128671), coalesce(worklistShardItemId#1128672L, 0), isnull(worklistShardItemId#1128672L), coalesce(version#1128673, 0), isnull(version#1128673), coalesce(product#1128674, ), isnull(product#1128674), coalesce(plant#1128675, ), isnull(plant#1128675), knownfloatingpointnormalized(normalizenanandzero(coalesce... [56237] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146321 { id="cluster_146321"; isCluster="true"; label="InMemoryTableScan"; 56303 [id="node_56303" labelType="html" label="MapPartitionsRDD [56303] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56304 [id="node_56304" labelType="html" label="MapPartitionsRDD [56304] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56305 [id="node_56305" labelType="html" label="MapPartitionsRDD [56305] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146316 { id="cluster_146316"; isCluster="true"; label="WholeStageCodegen (3)"; 56306 [id="node_56306" labelType="html" label="MapPartitionsRDD [56306] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146315 { id="cluster_146315"; isCluster="true"; label="Exchange"; 56307 [id="node_56307" labelType="html" label="MapPartitionsRDD [56307] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56199->56200; 56211->56212; 56215->56216; 56212->56217; 56216->56217; 56217->56218; 56218->56219; 56219->56220; 56227->56228; 56200->56229; 56228->56229; 56229->56230; 56220->56231; 56231->56232; 56232->56233; 56233->56234; 56230->56235; 56234->56235; 56235->56236; 56236->56237; 56237->56303; 56303->56304; 56304->56305; 56305->56306; 56306->56307; }