digraph G { id="graph_117007"; subgraph graph_stage_117007 { id="graph_stage_117007"; isCluster="true"; label="Stage 117007"; 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_146306 { id="cluster_146306"; isCluster="true"; label="Exchange"; 56333 [id="node_56333" labelType="html" label="ShuffledRowRDD [56333] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146301 { id="cluster_146301"; isCluster="true"; label="WholeStageCodegen (6)"; 56334 [id="node_56334" labelType="html" label="MapPartitionsRDD [56334] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146300 { id="cluster_146300"; isCluster="true"; label="SortAggregate"; 56335 [id="node_56335" labelType="html" label="MapPartitionsRDD [56335] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146299 { id="cluster_146299"; isCluster="true"; label="InMemoryTableScan"; 56336 [id="node_56336" labelType="html" label="MapPartitionsRDD [56336] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56337 [id="node_56337" labelType="html" label="SortAggregate(key=[demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216], functions=[first(kpis#1131244, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1131235, demandChannel#1131215, demandStream#1131216, kpis#1131377])\n+- *(6) Sort [demandChannel#1131215 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1131235 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1131216 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L, demandStream#1131216, 37), ENSURE_REQUIREMENTS, [plan_id=1756312]\n +- SortAggregate(key=[demandChannel#1131215, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1131235)) AS qty#1131235, worklistShardItemId#1100458L, demandStream#1131216], functions=[partial_first(kpis#1131244, false)], output=[demandChannel#1131215, shardId#1100457, qty#1131235, worklistShardItemId#1100458L,... [56337] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146468 { id="cluster_146468"; isCluster="true"; label="InMemoryTableScan"; 56377 [id="node_56377" labelType="html" label="MapPartitionsRDD [56377] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56378 [id="node_56378" labelType="html" label="MapPartitionsRDD [56378] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56379 [id="node_56379" labelType="html" label="MapPartitionsRDD [56379] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146464 { id="cluster_146464"; isCluster="true"; label="WholeStageCodegen (1)"; 56380 [id="node_56380" labelType="html" label="MapPartitionsRDD [56380] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146472 { id="cluster_146472"; isCluster="true"; label="InMemoryTableScan"; 56381 [id="node_56381" labelType="html" label="MapPartitionsRDD [56381] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56382 [id="node_56382" labelType="html" label="MapPartitionsRDD [56382] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56383 [id="node_56383" labelType="html" label="MapPartitionsRDD [56383] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146469 { id="cluster_146469"; isCluster="true"; label="WholeStageCodegen (2)"; 56384 [id="node_56384" labelType="html" label="MapPartitionsRDD [56384] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146463 { id="cluster_146463"; isCluster="true"; label="Union"; 56385 [id="node_56385" labelType="html" label="UnionRDD [56385] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146438 { id="cluster_146438"; isCluster="true"; label="WholeStageCodegen (5)"; 56386 [id="node_56386" labelType="html" label="MapPartitionsRDD [56386] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146437 { id="cluster_146437"; isCluster="true"; label="InMemoryTableScan"; 56387 [id="node_56387" labelType="html" label="MapPartitionsRDD [56387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56388 [id="node_56388" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1132048, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1132145, worklistShardItemId#1132146L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1128679, demandStream#1128680, kpis#1128714]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1128682 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1128679, demandStream#1128680, isNewlyCalculated#1128682, kpis#1128714, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1128682, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [56388] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146497 { id="cluster_146497"; isCluster="true"; label="InMemoryTableScan"; 56397 [id="node_56397" labelType="html" label="MapPartitionsRDD [56397] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56398 [id="node_56398" labelType="html" label="MapPartitionsRDD [56398] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56399 [id="node_56399" labelType="html" label="MapPartitionsRDD [56399] [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; 56333->56334; 56334->56335; 56335->56336; 56336->56337; 56237->56377; 56377->56378; 56378->56379; 56379->56380; 56337->56381; 56381->56382; 56382->56383; 56383->56384; 56380->56385; 56384->56385; 56385->56386; 56386->56387; 56387->56388; 56388->56397; 56397->56398; 56398->56399; }