digraph G { id="graph_109631"; subgraph graph_stage_109631 { id="graph_stage_109631"; isCluster="true"; label="Stage 109631"; subgraph cluster_137272 { id="cluster_137272"; isCluster="true"; label="Exchange"; 52678 [id="node_52678" labelType="html" label="ShuffledRowRDD [52678] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137269 { id="cluster_137269"; isCluster="true"; label="WholeStageCodegen (1)"; 52679 [id="node_52679" labelType="html" label="MapPartitionsRDD [52679] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137292 { id="cluster_137292"; isCluster="true"; label="Exchange"; 52690 [id="node_52690" labelType="html" label="ShuffledRowRDD [52690] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137289 { id="cluster_137289"; isCluster="true"; label="WholeStageCodegen (4)"; 52691 [id="node_52691" labelType="html" label="MapPartitionsRDD [52691] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137327 { id="cluster_137327"; isCluster="true"; label="Exchange"; 52694 [id="node_52694" labelType="html" label="ShuffledRowRDD [52694] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137324 { id="cluster_137324"; isCluster="true"; label="WholeStageCodegen (6)"; 52695 [id="node_52695" labelType="html" label="MapPartitionsRDD [52695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137281 { id="cluster_137281"; isCluster="true"; label="WholeStageCodegen (7)"; 52696 [id="node_52696" labelType="html" label="ZippedPartitionsRDD2 [52696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52697 [id="node_52697" labelType="html" label="MapPartitionsRDD [52697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137280 { id="cluster_137280"; isCluster="true"; label="InMemoryTableScan"; 52698 [id="node_52698" labelType="html" label="MapPartitionsRDD [52698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52699 [id="node_52699" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], 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=1686277]\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... [52699] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137278 { id="cluster_137278"; isCluster="true"; label="Exchange"; 52706 [id="node_52706" labelType="html" label="ShuffledRowRDD [52706] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137275 { id="cluster_137275"; isCluster="true"; label="WholeStageCodegen (4)"; 52707 [id="node_52707" labelType="html" label="MapPartitionsRDD [52707] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137261 { id="cluster_137261"; isCluster="true"; label="WholeStageCodegen (5)"; 52708 [id="node_52708" labelType="html" label="ZippedPartitionsRDD2 [52708] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52709 [id="node_52709" labelType="html" label="MapPartitionsRDD [52709] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137342 { id="cluster_137342"; isCluster="true"; label="InMemoryTableScan"; 52710 [id="node_52710" labelType="html" label="MapPartitionsRDD [52710] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52711 [id="node_52711" labelType="html" label="MapPartitionsRDD [52711] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52712 [id="node_52712" labelType="html" label="MapPartitionsRDD [52712] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137339 { id="cluster_137339"; isCluster="true"; label="WholeStageCodegen (6)"; 52713 [id="node_52713" labelType="html" label="MapPartitionsRDD [52713] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137260 { id="cluster_137260"; isCluster="true"; label="Union"; 52714 [id="node_52714" labelType="html" label="UnionRDD [52714] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137259 { id="cluster_137259"; isCluster="true"; label="InMemoryTableScan"; 52715 [id="node_52715" labelType="html" label="MapPartitionsRDD [52715] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52716 [id="node_52716" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1056211, null AS demandStream#1056212, [] AS kpis#1056246, true AS isNewlyCalculated#1056214]\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#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52716] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137563 { id="cluster_137563"; isCluster="true"; label="InMemoryTableScan"; 52782 [id="node_52782" labelType="html" label="MapPartitionsRDD [52782] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52783 [id="node_52783" labelType="html" label="MapPartitionsRDD [52783] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52784 [id="node_52784" labelType="html" label="MapPartitionsRDD [52784] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137558 { id="cluster_137558"; isCluster="true"; label="WholeStageCodegen (3)"; 52785 [id="node_52785" labelType="html" label="MapPartitionsRDD [52785] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137557 { id="cluster_137557"; isCluster="true"; label="Exchange"; 52786 [id="node_52786" labelType="html" label="MapPartitionsRDD [52786] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52678->52679; 52690->52691; 52694->52695; 52691->52696; 52695->52696; 52696->52697; 52697->52698; 52698->52699; 52706->52707; 52679->52708; 52707->52708; 52708->52709; 52699->52710; 52710->52711; 52711->52712; 52712->52713; 52709->52714; 52713->52714; 52714->52715; 52715->52716; 52716->52782; 52782->52783; 52783->52784; 52784->52785; 52785->52786; }