digraph G { id="graph_101760"; subgraph graph_stage_101760 { id="graph_stage_101760"; isCluster="true"; label="Stage 101760"; 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_127069 { id="cluster_127069"; isCluster="true"; label="InMemoryTableScan"; 48565 [id="node_48565" labelType="html" label="MapPartitionsRDD [48565] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48566 [id="node_48566" labelType="html" label="MapPartitionsRDD [48566] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48567 [id="node_48567" labelType="html" label="MapPartitionsRDD [48567] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127065 { id="cluster_127065"; isCluster="true"; label="WholeStageCodegen (3)"; 48568 [id="node_48568" labelType="html" label="MapPartitionsRDD [48568] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127064 { id="cluster_127064"; isCluster="true"; label="Exchange"; 48569 [id="node_48569" labelType="html" label="MapPartitionsRDD [48569] [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; 48435->48565; 48565->48566; 48566->48567; 48567->48568; 48568->48569; }