digraph G { id="graph_102323"; subgraph graph_stage_102323 { id="graph_stage_102323"; isCluster="true"; label="Stage 102323"; subgraph cluster_127270 { id="cluster_127270"; isCluster="true"; label="Exchange"; 48661 [id="node_48661" labelType="html" label="ShuffledRowRDD [48661] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127267 { id="cluster_127267"; isCluster="true"; label="WholeStageCodegen (1)"; 48662 [id="node_48662" labelType="html" label="MapPartitionsRDD [48662] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127290 { id="cluster_127290"; isCluster="true"; label="Exchange"; 48673 [id="node_48673" labelType="html" label="ShuffledRowRDD [48673] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127287 { id="cluster_127287"; isCluster="true"; label="WholeStageCodegen (4)"; 48674 [id="node_48674" labelType="html" label="MapPartitionsRDD [48674] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127325 { id="cluster_127325"; isCluster="true"; label="Exchange"; 48677 [id="node_48677" labelType="html" label="ShuffledRowRDD [48677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127322 { id="cluster_127322"; isCluster="true"; label="WholeStageCodegen (6)"; 48678 [id="node_48678" labelType="html" label="MapPartitionsRDD [48678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127279 { id="cluster_127279"; isCluster="true"; label="WholeStageCodegen (7)"; 48679 [id="node_48679" labelType="html" label="ZippedPartitionsRDD2 [48679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48680 [id="node_48680" labelType="html" label="MapPartitionsRDD [48680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127278 { id="cluster_127278"; isCluster="true"; label="InMemoryTableScan"; 48681 [id="node_48681" labelType="html" label="MapPartitionsRDD [48681] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48682 [id="node_48682" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#973191 AS qty#973193, demandChannel#973186, demandStream#973187, cachedKpis#973192 AS kpis#973194]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#973190L, cachedShardId#973189], 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=1622545]\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=1622541]\n : +- *(2) Has... [48682] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127276 { id="cluster_127276"; isCluster="true"; label="Exchange"; 48689 [id="node_48689" labelType="html" label="ShuffledRowRDD [48689] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127273 { id="cluster_127273"; isCluster="true"; label="WholeStageCodegen (4)"; 48690 [id="node_48690" labelType="html" label="MapPartitionsRDD [48690] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127260 { id="cluster_127260"; isCluster="true"; label="WholeStageCodegen (5)"; 48691 [id="node_48691" labelType="html" label="ZippedPartitionsRDD2 [48691] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48692 [id="node_48692" labelType="html" label="MapPartitionsRDD [48692] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127340 { id="cluster_127340"; isCluster="true"; label="InMemoryTableScan"; 48693 [id="node_48693" labelType="html" label="MapPartitionsRDD [48693] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48694 [id="node_48694" labelType="html" label="MapPartitionsRDD [48694] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48695 [id="node_48695" labelType="html" label="MapPartitionsRDD [48695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127337 { id="cluster_127337"; isCluster="true"; label="WholeStageCodegen (6)"; 48696 [id="node_48696" labelType="html" label="MapPartitionsRDD [48696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127258 { id="cluster_127258"; isCluster="true"; label="Union"; 48697 [id="node_48697" labelType="html" label="UnionRDD [48697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127257 { id="cluster_127257"; isCluster="true"; label="InMemoryTableScan"; 48698 [id="node_48698" labelType="html" label="MapPartitionsRDD [48698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48699 [id="node_48699" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#973426, null AS demandStream#973427, [] AS kpis#973461, true AS isNewlyCalculated#973429]\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#973418, ), isnull(shardId#973418), coalesce(worklistShardItemId#973419L, 0), isnull(worklistShardItemId#973419L), coalesce(version#973420, 0), isnull(version#973420), coalesce(product#973421, ), isnull(product#973421), coalesce(plant#973422, ), isnull(plant#973422), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#973193, 0.0))), isnull(qty#... [48699] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127546 { id="cluster_127546"; isCluster="true"; label="Exchange"; 48795 [id="node_48795" labelType="html" label="ShuffledRowRDD [48795] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127541 { id="cluster_127541"; isCluster="true"; label="WholeStageCodegen (6)"; 48796 [id="node_48796" labelType="html" label="MapPartitionsRDD [48796] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127540 { id="cluster_127540"; isCluster="true"; label="SortAggregate"; 48797 [id="node_48797" labelType="html" label="MapPartitionsRDD [48797] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127539 { id="cluster_127539"; isCluster="true"; label="InMemoryTableScan"; 48798 [id="node_48798" labelType="html" label="MapPartitionsRDD [48798] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48799 [id="node_48799" labelType="html" label="SortAggregate(key=[demandChannel#975962, shardId#943631, qty#975982, worklistShardItemId#943632L, demandStream#975963], functions=[first(kpis#975991, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#975982, demandChannel#975962, demandStream#975963, kpis#976124])\n+- *(6) Sort [demandChannel#975962 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#975982 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#975963 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#975962, shardId#943631, qty#975982, worklistShardItemId#943632L, demandStream#975963, 37), ENSURE_REQUIREMENTS, [plan_id=1623475]\n +- SortAggregate(key=[demandChannel#975962, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#975982)) AS qty#975982, worklistShardItemId#943632L, demandStream#975963], functions=[partial_first(kpis#975991, false)], output=[demandChannel#975962, shardId#943631, qty#975982, worklistShardItemId#943632L, demandStream#975963, first#97620... [48799] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127708 { id="cluster_127708"; isCluster="true"; label="InMemoryTableScan"; 48839 [id="node_48839" labelType="html" label="MapPartitionsRDD [48839] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48840 [id="node_48840" labelType="html" label="MapPartitionsRDD [48840] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48841 [id="node_48841" labelType="html" label="MapPartitionsRDD [48841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127704 { id="cluster_127704"; isCluster="true"; label="WholeStageCodegen (1)"; 48842 [id="node_48842" labelType="html" label="MapPartitionsRDD [48842] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127712 { id="cluster_127712"; isCluster="true"; label="InMemoryTableScan"; 48843 [id="node_48843" labelType="html" label="MapPartitionsRDD [48843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48844 [id="node_48844" labelType="html" label="MapPartitionsRDD [48844] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48845 [id="node_48845" labelType="html" label="MapPartitionsRDD [48845] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127709 { id="cluster_127709"; isCluster="true"; label="WholeStageCodegen (2)"; 48846 [id="node_48846" labelType="html" label="MapPartitionsRDD [48846] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127703 { id="cluster_127703"; isCluster="true"; label="Union"; 48847 [id="node_48847" labelType="html" label="UnionRDD [48847] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127678 { id="cluster_127678"; isCluster="true"; label="WholeStageCodegen (5)"; 48848 [id="node_48848" labelType="html" label="MapPartitionsRDD [48848] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127677 { id="cluster_127677"; isCluster="true"; label="InMemoryTableScan"; 48849 [id="node_48849" labelType="html" label="MapPartitionsRDD [48849] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48850 [id="node_48850" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#976795, qty#943638, demandChannel#973426, demandStream#973427, kpis#973461]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#976892, worklistShardItemId#976893L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#973426, demandStream#973427, kpis#973461]\n : : +- *(1) Filter ((NOT isNewlyCalculated#973429 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#973426, demandStream#973427, isNewlyCalculated#973429, kpis#973461, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#973429, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#973426, demandStream#973427... [48850] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127737 { id="cluster_127737"; isCluster="true"; label="InMemoryTableScan"; 48859 [id="node_48859" labelType="html" label="MapPartitionsRDD [48859] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48860 [id="node_48860" labelType="html" label="MapPartitionsRDD [48860] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48861 [id="node_48861" labelType="html" label="MapPartitionsRDD [48861] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 48661->48662; 48673->48674; 48677->48678; 48674->48679; 48678->48679; 48679->48680; 48680->48681; 48681->48682; 48689->48690; 48662->48691; 48690->48691; 48691->48692; 48682->48693; 48693->48694; 48694->48695; 48695->48696; 48692->48697; 48696->48697; 48697->48698; 48698->48699; 48795->48796; 48796->48797; 48797->48798; 48798->48799; 48699->48839; 48839->48840; 48840->48841; 48841->48842; 48799->48843; 48843->48844; 48844->48845; 48845->48846; 48842->48847; 48846->48847; 48847->48848; 48848->48849; 48849->48850; 48850->48859; 48859->48860; 48860->48861; }