digraph G { id="graph_119306"; subgraph graph_stage_119306 { id="graph_stage_119306"; isCluster="true"; label="Stage 119306"; 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}"]; } subgraph cluster_149413 { id="cluster_149413"; isCluster="true"; label="Exchange"; 57655 [id="node_57655" labelType="html" label="ShuffledRowRDD [57655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149408 { id="cluster_149408"; isCluster="true"; label="WholeStageCodegen (6)"; 57656 [id="node_57656" labelType="html" label="MapPartitionsRDD [57656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149407 { id="cluster_149407"; isCluster="true"; label="SortAggregate"; 57657 [id="node_57657" labelType="html" label="MapPartitionsRDD [57657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149406 { id="cluster_149406"; isCluster="true"; label="InMemoryTableScan"; 57658 [id="node_57658" labelType="html" label="MapPartitionsRDD [57658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57659 [id="node_57659" labelType="html" label="SortAggregate(key=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[first(kpis#1159034, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1159025, demandChannel#1159005, demandStream#1159006, kpis#1159167])\n+- *(6) Sort [demandChannel#1159005 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1159025 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1159006 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006, 37), ENSURE_REQUIREMENTS, [plan_id=1764206]\n +- SortAggregate(key=[demandChannel#1159005, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1159025)) AS qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[partial_first(kpis#1159034, false)], output=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L,... [57659] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149573 { id="cluster_149573"; isCluster="true"; label="InMemoryTableScan"; 57697 [id="node_57697" labelType="html" label="MapPartitionsRDD [57697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57698 [id="node_57698" labelType="html" label="MapPartitionsRDD [57698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57699 [id="node_57699" labelType="html" label="MapPartitionsRDD [57699] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149569 { id="cluster_149569"; isCluster="true"; label="WholeStageCodegen (1)"; 57700 [id="node_57700" labelType="html" label="MapPartitionsRDD [57700] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149577 { id="cluster_149577"; isCluster="true"; label="InMemoryTableScan"; 57701 [id="node_57701" labelType="html" label="MapPartitionsRDD [57701] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57702 [id="node_57702" labelType="html" label="MapPartitionsRDD [57702] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57703 [id="node_57703" labelType="html" label="MapPartitionsRDD [57703] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149574 { id="cluster_149574"; isCluster="true"; label="WholeStageCodegen (2)"; 57704 [id="node_57704" labelType="html" label="MapPartitionsRDD [57704] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149568 { id="cluster_149568"; isCluster="true"; label="Union"; 57705 [id="node_57705" labelType="html" label="UnionRDD [57705] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149544 { id="cluster_149544"; isCluster="true"; label="WholeStageCodegen (5)"; 57706 [id="node_57706" labelType="html" label="MapPartitionsRDD [57706] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149543 { id="cluster_149543"; isCluster="true"; label="InMemoryTableScan"; 57707 [id="node_57707" labelType="html" label="MapPartitionsRDD [57707] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57708 [id="node_57708" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1159838, qty#1100464, demandChannel#1156469, demandStream#1156470, kpis#1156504]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1159935, worklistShardItemId#1159936L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1156469, demandStream#1156470, kpis#1156504]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1156472 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1156469, demandStream#1156470, isNewlyCalculated#1156472, kpis#1156504, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1156472, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [57708] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57709 [id="node_57709" labelType="html" label="MapPartitionsRDD [57709] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57710 [id="node_57710" labelType="html" label="MapPartitionsRDD [57710] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57711 [id="node_57711" labelType="html" label="MapPartitionsRDD [57711] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149542 { id="cluster_149542"; isCluster="true"; label="CollectLimit"; 57712 [id="node_57712" labelType="html" label="MapPartitionsRDD [57712] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57713 [id="node_57713" labelType="html" label="MapPartitionsRDD [57713] [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; 57655->57656; 57656->57657; 57657->57658; 57658->57659; 57559->57697; 57697->57698; 57698->57699; 57699->57700; 57659->57701; 57701->57702; 57702->57703; 57703->57704; 57700->57705; 57704->57705; 57705->57706; 57706->57707; 57707->57708; 57708->57709; 57709->57710; 57710->57711; 57711->57712; 57712->57713; }