digraph G { id="graph_113330"; subgraph graph_stage_113330 { id="graph_stage_113330"; isCluster="true"; label="Stage 113330"; 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_140713 { id="cluster_140713"; isCluster="true"; label="Exchange"; 54156 [id="node_54156" labelType="html" label="ShuffledRowRDD [54156] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140707 { id="cluster_140707"; isCluster="true"; label="WholeStageCodegen (6)"; 54157 [id="node_54157" labelType="html" label="MapPartitionsRDD [54157] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140706 { id="cluster_140706"; isCluster="true"; label="SortAggregate"; 54158 [id="node_54158" labelType="html" label="MapPartitionsRDD [54158] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140705 { id="cluster_140705"; isCluster="true"; label="InMemoryTableScan"; 54159 [id="node_54159" labelType="html" label="MapPartitionsRDD [54159] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54160 [id="node_54160" labelType="html" label="SortAggregate(key=[demandChannel#1086836, shardId#1011815, qty#1086856, worklistShardItemId#1011816L, demandStream#1086837], functions=[first(kpis#1086865, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1086856, demandChannel#1086836, demandStream#1086837, kpis#1086998])\n+- *(6) Sort [demandChannel#1086836 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1086856 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1086837 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1086836, shardId#1011815, qty#1086856, worklistShardItemId#1011816L, demandStream#1086837, 37), ENSURE_REQUIREMENTS, [plan_id=1695213]\n +- SortAggregate(key=[demandChannel#1086836, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1086856)) AS qty#1086856, worklistShardItemId#1011816L, demandStream#1086837], functions=[partial_first(kpis#1086865, false)], output=[demandChannel#1086836, shardId#1011815, qty#1086856, worklistShardItemId#1011816L,... [54160] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140872 { id="cluster_140872"; isCluster="true"; label="InMemoryTableScan"; 54198 [id="node_54198" labelType="html" label="MapPartitionsRDD [54198] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54199 [id="node_54199" labelType="html" label="MapPartitionsRDD [54199] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54200 [id="node_54200" labelType="html" label="MapPartitionsRDD [54200] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140868 { id="cluster_140868"; isCluster="true"; label="WholeStageCodegen (1)"; 54201 [id="node_54201" labelType="html" label="MapPartitionsRDD [54201] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140876 { id="cluster_140876"; isCluster="true"; label="InMemoryTableScan"; 54202 [id="node_54202" labelType="html" label="MapPartitionsRDD [54202] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54203 [id="node_54203" labelType="html" label="MapPartitionsRDD [54203] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54204 [id="node_54204" labelType="html" label="MapPartitionsRDD [54204] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140873 { id="cluster_140873"; isCluster="true"; label="WholeStageCodegen (2)"; 54205 [id="node_54205" labelType="html" label="MapPartitionsRDD [54205] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140867 { id="cluster_140867"; isCluster="true"; label="Union"; 54206 [id="node_54206" labelType="html" label="UnionRDD [54206] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140843 { id="cluster_140843"; isCluster="true"; label="WholeStageCodegen (5)"; 54207 [id="node_54207" labelType="html" label="MapPartitionsRDD [54207] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140842 { id="cluster_140842"; isCluster="true"; label="InMemoryTableScan"; 54208 [id="node_54208" labelType="html" label="MapPartitionsRDD [54208] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54209 [id="node_54209" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1087669, qty#1011822, demandChannel#1084300, demandStream#1084301, kpis#1084335]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1087766, worklistShardItemId#1087767L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1084300, demandStream#1084301, kpis#1084335]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1084303 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1084300, demandStream#1084301, isNewlyCalculated#1084303, kpis#1084335, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1084303, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [54209] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54210 [id="node_54210" labelType="html" label="MapPartitionsRDD [54210] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54211 [id="node_54211" labelType="html" label="MapPartitionsRDD [54211] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54212 [id="node_54212" labelType="html" label="MapPartitionsRDD [54212] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_140841 { id="cluster_140841"; isCluster="true"; label="CollectLimit"; 54213 [id="node_54213" labelType="html" label="MapPartitionsRDD [54213] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54214 [id="node_54214" labelType="html" label="MapPartitionsRDD [54214] [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; 54156->54157; 54157->54158; 54158->54159; 54159->54160; 54060->54198; 54198->54199; 54199->54200; 54200->54201; 54160->54202; 54202->54203; 54203->54204; 54204->54205; 54201->54206; 54205->54206; 54206->54207; 54207->54208; 54208->54209; 54209->54210; 54210->54211; 54211->54212; 54212->54213; 54213->54214; }