digraph G { id="graph_112910"; subgraph graph_stage_112910 { id="graph_stage_112910"; isCluster="true"; label="Stage 112910"; subgraph cluster_140436 { id="cluster_140436"; isCluster="true"; label="Exchange"; 54022 [id="node_54022" labelType="html" label="ShuffledRowRDD [54022] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140433 { id="cluster_140433"; isCluster="true"; label="WholeStageCodegen (1)"; 54023 [id="node_54023" labelType="html" label="MapPartitionsRDD [54023] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140456 { id="cluster_140456"; isCluster="true"; label="Exchange"; 54034 [id="node_54034" labelType="html" label="ShuffledRowRDD [54034] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140453 { id="cluster_140453"; isCluster="true"; label="WholeStageCodegen (4)"; 54035 [id="node_54035" labelType="html" label="MapPartitionsRDD [54035] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140491 { id="cluster_140491"; isCluster="true"; label="Exchange"; 54038 [id="node_54038" labelType="html" label="ShuffledRowRDD [54038] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140488 { id="cluster_140488"; isCluster="true"; label="WholeStageCodegen (6)"; 54039 [id="node_54039" labelType="html" label="MapPartitionsRDD [54039] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140445 { id="cluster_140445"; isCluster="true"; label="WholeStageCodegen (7)"; 54040 [id="node_54040" labelType="html" label="ZippedPartitionsRDD2 [54040] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54041 [id="node_54041" labelType="html" label="MapPartitionsRDD [54041] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140444 { id="cluster_140444"; isCluster="true"; label="InMemoryTableScan"; 54042 [id="node_54042" labelType="html" label="MapPartitionsRDD [54042] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54043 [id="node_54043" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1084065 AS qty#1084067, demandChannel#1084060, demandStream#1084061, cachedKpis#1084066 AS kpis#1084068]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1084064L, cachedShardId#1084063], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1694283]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [54043] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140442 { id="cluster_140442"; isCluster="true"; label="Exchange"; 54050 [id="node_54050" labelType="html" label="ShuffledRowRDD [54050] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140439 { id="cluster_140439"; isCluster="true"; label="WholeStageCodegen (4)"; 54051 [id="node_54051" labelType="html" label="MapPartitionsRDD [54051] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140425 { id="cluster_140425"; isCluster="true"; label="WholeStageCodegen (5)"; 54052 [id="node_54052" labelType="html" label="ZippedPartitionsRDD2 [54052] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54053 [id="node_54053" labelType="html" label="MapPartitionsRDD [54053] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140506 { id="cluster_140506"; isCluster="true"; label="InMemoryTableScan"; 54054 [id="node_54054" labelType="html" label="MapPartitionsRDD [54054] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54055 [id="node_54055" labelType="html" label="MapPartitionsRDD [54055] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54056 [id="node_54056" labelType="html" label="MapPartitionsRDD [54056] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140503 { id="cluster_140503"; isCluster="true"; label="WholeStageCodegen (6)"; 54057 [id="node_54057" labelType="html" label="MapPartitionsRDD [54057] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140424 { id="cluster_140424"; isCluster="true"; label="Union"; 54058 [id="node_54058" labelType="html" label="UnionRDD [54058] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140423 { id="cluster_140423"; isCluster="true"; label="InMemoryTableScan"; 54059 [id="node_54059" labelType="html" label="MapPartitionsRDD [54059] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54060 [id="node_54060" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1084300, null AS demandStream#1084301, [] AS kpis#1084335, true AS isNewlyCalculated#1084303]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1084292, ), isnull(shardId#1084292), coalesce(worklistShardItemId#1084293L, 0), isnull(worklistShardItemId#1084293L), coalesce(version#1084294, 0), isnull(version#1084294), coalesce(product#1084295, ), isnull(product#1084295), coalesce(plant#1084296, ), isnull(plant#1084296), knownfloatingpointnormalized(normalizenanandzero(coalesce... [54060] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140640 { id="cluster_140640"; isCluster="true"; label="InMemoryTableScan"; 54099 [id="node_54099" labelType="html" label="MapPartitionsRDD [54099] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54100 [id="node_54100" labelType="html" label="MapPartitionsRDD [54100] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54101 [id="node_54101" labelType="html" label="MapPartitionsRDD [54101] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140636 { id="cluster_140636"; isCluster="true"; label="WholeStageCodegen (11)"; 54102 [id="node_54102" labelType="html" label="MapPartitionsRDD [54102] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140635 { id="cluster_140635"; isCluster="true"; label="ObjectHashAggregate"; 54103 [id="node_54103" labelType="html" label="MapPartitionsRDD [54103] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140634 { id="cluster_140634"; isCluster="true"; label="Exchange"; 54104 [id="node_54104" labelType="html" label="MapPartitionsRDD [54104] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54022->54023; 54034->54035; 54038->54039; 54035->54040; 54039->54040; 54040->54041; 54041->54042; 54042->54043; 54050->54051; 54023->54052; 54051->54052; 54052->54053; 54043->54054; 54054->54055; 54055->54056; 54056->54057; 54053->54058; 54057->54058; 54058->54059; 54059->54060; 54060->54099; 54099->54100; 54100->54101; 54101->54102; 54102->54103; 54103->54104; }