digraph G { id="graph_106531"; subgraph graph_stage_106531 { id="graph_stage_106531"; isCluster="true"; label="Stage 106531"; subgraph cluster_134788 { id="cluster_134788"; isCluster="true"; label="Exchange"; 51622 [id="node_51622" labelType="html" label="ShuffledRowRDD [51622] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134785 { id="cluster_134785"; isCluster="true"; label="WholeStageCodegen (1)"; 51623 [id="node_51623" labelType="html" label="MapPartitionsRDD [51623] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134808 { id="cluster_134808"; isCluster="true"; label="Exchange"; 51634 [id="node_51634" labelType="html" label="ShuffledRowRDD [51634] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134805 { id="cluster_134805"; isCluster="true"; label="WholeStageCodegen (4)"; 51635 [id="node_51635" labelType="html" label="MapPartitionsRDD [51635] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134843 { id="cluster_134843"; isCluster="true"; label="Exchange"; 51638 [id="node_51638" labelType="html" label="ShuffledRowRDD [51638] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134840 { id="cluster_134840"; isCluster="true"; label="WholeStageCodegen (6)"; 51639 [id="node_51639" labelType="html" label="MapPartitionsRDD [51639] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134797 { id="cluster_134797"; isCluster="true"; label="WholeStageCodegen (7)"; 51640 [id="node_51640" labelType="html" label="ZippedPartitionsRDD2 [51640] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51641 [id="node_51641" labelType="html" label="MapPartitionsRDD [51641] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134796 { id="cluster_134796"; isCluster="true"; label="InMemoryTableScan"; 51642 [id="node_51642" labelType="html" label="MapPartitionsRDD [51642] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51643 [id="node_51643" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1033744 AS qty#1033746, demandChannel#1033739, demandStream#1033740, cachedKpis#1033745 AS kpis#1033747]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1033743L, cachedShardId#1033742], 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=1680014]\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... [51643] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134794 { id="cluster_134794"; isCluster="true"; label="Exchange"; 51650 [id="node_51650" labelType="html" label="ShuffledRowRDD [51650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134791 { id="cluster_134791"; isCluster="true"; label="WholeStageCodegen (4)"; 51651 [id="node_51651" labelType="html" label="MapPartitionsRDD [51651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134777 { id="cluster_134777"; isCluster="true"; label="WholeStageCodegen (5)"; 51652 [id="node_51652" labelType="html" label="ZippedPartitionsRDD2 [51652] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51653 [id="node_51653" labelType="html" label="MapPartitionsRDD [51653] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134858 { id="cluster_134858"; isCluster="true"; label="InMemoryTableScan"; 51654 [id="node_51654" labelType="html" label="MapPartitionsRDD [51654] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51655 [id="node_51655" labelType="html" label="MapPartitionsRDD [51655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51656 [id="node_51656" labelType="html" label="MapPartitionsRDD [51656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134855 { id="cluster_134855"; isCluster="true"; label="WholeStageCodegen (6)"; 51657 [id="node_51657" labelType="html" label="MapPartitionsRDD [51657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134776 { id="cluster_134776"; isCluster="true"; label="Union"; 51658 [id="node_51658" labelType="html" label="UnionRDD [51658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134775 { id="cluster_134775"; isCluster="true"; label="InMemoryTableScan"; 51659 [id="node_51659" labelType="html" label="MapPartitionsRDD [51659] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51660 [id="node_51660" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1033979, null AS demandStream#1033980, [] AS kpis#1034014, true AS isNewlyCalculated#1033982]\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#1033971, ), isnull(shardId#1033971), coalesce(worklistShardItemId#1033972L, 0), isnull(worklistShardItemId#1033972L), coalesce(version#1033973, 0), isnull(version#1033973), coalesce(product#1033974, ), isnull(product#1033974), coalesce(plant#1033975, ), isnull(plant#1033975), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51660] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135079 { id="cluster_135079"; isCluster="true"; label="InMemoryTableScan"; 51726 [id="node_51726" labelType="html" label="MapPartitionsRDD [51726] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51727 [id="node_51727" labelType="html" label="MapPartitionsRDD [51727] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51728 [id="node_51728" labelType="html" label="MapPartitionsRDD [51728] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135074 { id="cluster_135074"; isCluster="true"; label="WholeStageCodegen (3)"; 51729 [id="node_51729" labelType="html" label="MapPartitionsRDD [51729] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135073 { id="cluster_135073"; isCluster="true"; label="Exchange"; 51730 [id="node_51730" labelType="html" label="MapPartitionsRDD [51730] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51622->51623; 51634->51635; 51638->51639; 51635->51640; 51639->51640; 51640->51641; 51641->51642; 51642->51643; 51650->51651; 51623->51652; 51651->51652; 51652->51653; 51643->51654; 51654->51655; 51655->51656; 51656->51657; 51653->51658; 51657->51658; 51658->51659; 51659->51660; 51660->51726; 51726->51727; 51727->51728; 51728->51729; 51729->51730; }