digraph G { id="graph_101796"; subgraph graph_stage_101796 { id="graph_stage_101796"; isCluster="true"; label="Stage 101796"; subgraph cluster_126649 { id="cluster_126649"; isCluster="true"; label="Exchange"; 48397 [id="node_48397" labelType="html" label="ShuffledRowRDD [48397] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126646 { id="cluster_126646"; isCluster="true"; label="WholeStageCodegen (1)"; 48398 [id="node_48398" labelType="html" label="MapPartitionsRDD [48398] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126668 { id="cluster_126668"; isCluster="true"; label="Exchange"; 48409 [id="node_48409" labelType="html" label="ShuffledRowRDD [48409] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126665 { id="cluster_126665"; isCluster="true"; label="WholeStageCodegen (4)"; 48410 [id="node_48410" labelType="html" label="MapPartitionsRDD [48410] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126704 { id="cluster_126704"; isCluster="true"; label="Exchange"; 48413 [id="node_48413" labelType="html" label="ShuffledRowRDD [48413] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126701 { id="cluster_126701"; isCluster="true"; label="WholeStageCodegen (6)"; 48414 [id="node_48414" labelType="html" label="MapPartitionsRDD [48414] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126658 { id="cluster_126658"; isCluster="true"; label="WholeStageCodegen (7)"; 48415 [id="node_48415" labelType="html" label="ZippedPartitionsRDD2 [48415] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48416 [id="node_48416" labelType="html" label="MapPartitionsRDD [48416] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126657 { id="cluster_126657"; isCluster="true"; label="InMemoryTableScan"; 48417 [id="node_48417" labelType="html" label="MapPartitionsRDD [48417] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48418 [id="node_48418" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#967633 AS qty#967635, demandChannel#967628, demandStream#967629, cachedKpis#967634 AS kpis#967636]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#967632L, cachedShardId#967631], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1620955]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1620951]\n : +- *(2) Has... [48418] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126655 { id="cluster_126655"; isCluster="true"; label="Exchange"; 48425 [id="node_48425" labelType="html" label="ShuffledRowRDD [48425] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126652 { id="cluster_126652"; isCluster="true"; label="WholeStageCodegen (4)"; 48426 [id="node_48426" labelType="html" label="MapPartitionsRDD [48426] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126638 { id="cluster_126638"; isCluster="true"; label="WholeStageCodegen (5)"; 48427 [id="node_48427" labelType="html" label="ZippedPartitionsRDD2 [48427] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48428 [id="node_48428" labelType="html" label="MapPartitionsRDD [48428] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126719 { id="cluster_126719"; isCluster="true"; label="InMemoryTableScan"; 48429 [id="node_48429" labelType="html" label="MapPartitionsRDD [48429] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48430 [id="node_48430" labelType="html" label="MapPartitionsRDD [48430] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48431 [id="node_48431" labelType="html" label="MapPartitionsRDD [48431] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126716 { id="cluster_126716"; isCluster="true"; label="WholeStageCodegen (6)"; 48432 [id="node_48432" labelType="html" label="MapPartitionsRDD [48432] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126637 { id="cluster_126637"; isCluster="true"; label="Union"; 48433 [id="node_48433" labelType="html" label="UnionRDD [48433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126636 { id="cluster_126636"; isCluster="true"; label="InMemoryTableScan"; 48434 [id="node_48434" labelType="html" label="MapPartitionsRDD [48434] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48435 [id="node_48435" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#967868, null AS demandStream#967869, [] AS kpis#967903, true AS isNewlyCalculated#967871]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#967860, ), isnull(shardId#967860), coalesce(worklistShardItemId#967861L, 0), isnull(worklistShardItemId#967861L), coalesce(version#967862, 0), isnull(version#967862), coalesce(product#967863, ), isnull(product#967863), coalesce(plant#967864, ), isnull(plant#967864), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#967635, 0.0))), isnull(qty#... [48435] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126925 { id="cluster_126925"; isCluster="true"; label="Exchange"; 48531 [id="node_48531" labelType="html" label="ShuffledRowRDD [48531] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126920 { id="cluster_126920"; isCluster="true"; label="WholeStageCodegen (6)"; 48532 [id="node_48532" labelType="html" label="MapPartitionsRDD [48532] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126919 { id="cluster_126919"; isCluster="true"; label="SortAggregate"; 48533 [id="node_48533" labelType="html" label="MapPartitionsRDD [48533] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_126918 { id="cluster_126918"; isCluster="true"; label="InMemoryTableScan"; 48534 [id="node_48534" labelType="html" label="MapPartitionsRDD [48534] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48535 [id="node_48535" labelType="html" label="SortAggregate(key=[demandChannel#970404, shardId#943631, qty#970424, worklistShardItemId#943632L, demandStream#970405], functions=[first(kpis#970433, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#970424, demandChannel#970404, demandStream#970405, kpis#970566])\n+- *(6) Sort [demandChannel#970404 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#970424 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#970405 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#970404, shardId#943631, qty#970424, worklistShardItemId#943632L, demandStream#970405, 37), ENSURE_REQUIREMENTS, [plan_id=1621885]\n +- SortAggregate(key=[demandChannel#970404, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#970424)) AS qty#970424, worklistShardItemId#943632L, demandStream#970405], functions=[partial_first(kpis#970433, false)], output=[demandChannel#970404, shardId#943631, qty#970424, worklistShardItemId#943632L, demandStream#970405, first#97064... [48535] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127085 { id="cluster_127085"; isCluster="true"; label="InMemoryTableScan"; 48573 [id="node_48573" labelType="html" label="MapPartitionsRDD [48573] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48574 [id="node_48574" labelType="html" label="MapPartitionsRDD [48574] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48575 [id="node_48575" labelType="html" label="MapPartitionsRDD [48575] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127081 { id="cluster_127081"; isCluster="true"; label="WholeStageCodegen (1)"; 48576 [id="node_48576" labelType="html" label="MapPartitionsRDD [48576] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127089 { id="cluster_127089"; isCluster="true"; label="InMemoryTableScan"; 48577 [id="node_48577" labelType="html" label="MapPartitionsRDD [48577] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48578 [id="node_48578" labelType="html" label="MapPartitionsRDD [48578] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48579 [id="node_48579" labelType="html" label="MapPartitionsRDD [48579] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127086 { id="cluster_127086"; isCluster="true"; label="WholeStageCodegen (2)"; 48580 [id="node_48580" labelType="html" label="MapPartitionsRDD [48580] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127080 { id="cluster_127080"; isCluster="true"; label="Union"; 48581 [id="node_48581" labelType="html" label="UnionRDD [48581] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127056 { id="cluster_127056"; isCluster="true"; label="WholeStageCodegen (5)"; 48582 [id="node_48582" labelType="html" label="MapPartitionsRDD [48582] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127055 { id="cluster_127055"; isCluster="true"; label="InMemoryTableScan"; 48583 [id="node_48583" labelType="html" label="MapPartitionsRDD [48583] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48584 [id="node_48584" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#971237, qty#943638, demandChannel#967868, demandStream#967869, kpis#967903]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#971334, worklistShardItemId#971335L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#967868, demandStream#967869, kpis#967903]\n : : +- *(1) Filter ((NOT isNewlyCalculated#967871 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#967868, demandStream#967869, isNewlyCalculated#967871, kpis#967903, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#967871, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#967868, demandStream#967869... [48584] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48585 [id="node_48585" labelType="html" label="MapPartitionsRDD [48585] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48586 [id="node_48586" labelType="html" label="MapPartitionsRDD [48586] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48587 [id="node_48587" labelType="html" label="MapPartitionsRDD [48587] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127054 { id="cluster_127054"; isCluster="true"; label="CollectLimit"; 48588 [id="node_48588" labelType="html" label="MapPartitionsRDD [48588] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48589 [id="node_48589" labelType="html" label="MapPartitionsRDD [48589] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 48397->48398; 48409->48410; 48413->48414; 48410->48415; 48414->48415; 48415->48416; 48416->48417; 48417->48418; 48425->48426; 48398->48427; 48426->48427; 48427->48428; 48418->48429; 48429->48430; 48430->48431; 48431->48432; 48428->48433; 48432->48433; 48433->48434; 48434->48435; 48531->48532; 48532->48533; 48533->48534; 48534->48535; 48435->48573; 48573->48574; 48574->48575; 48575->48576; 48535->48577; 48577->48578; 48578->48579; 48579->48580; 48576->48581; 48580->48581; 48581->48582; 48582->48583; 48583->48584; 48584->48585; 48585->48586; 48586->48587; 48587->48588; 48588->48589; }