digraph G { id="graph_93481"; subgraph graph_stage_93481 { id="graph_stage_93481"; isCluster="true"; label="Stage 93481"; subgraph cluster_111720 { id="cluster_111720"; isCluster="true"; label="Exchange"; 42862 [id="node_42862" labelType="html" label="ShuffledRowRDD [42862] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111717 { id="cluster_111717"; isCluster="true"; label="WholeStageCodegen (1)"; 42863 [id="node_42863" labelType="html" label="MapPartitionsRDD [42863] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111740 { id="cluster_111740"; isCluster="true"; label="Exchange"; 42874 [id="node_42874" labelType="html" label="ShuffledRowRDD [42874] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111737 { id="cluster_111737"; isCluster="true"; label="WholeStageCodegen (4)"; 42875 [id="node_42875" labelType="html" label="MapPartitionsRDD [42875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111775 { id="cluster_111775"; isCluster="true"; label="Exchange"; 42878 [id="node_42878" labelType="html" label="ShuffledRowRDD [42878] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111772 { id="cluster_111772"; isCluster="true"; label="WholeStageCodegen (6)"; 42879 [id="node_42879" labelType="html" label="MapPartitionsRDD [42879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111729 { id="cluster_111729"; isCluster="true"; label="WholeStageCodegen (7)"; 42880 [id="node_42880" labelType="html" label="ZippedPartitionsRDD2 [42880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42881 [id="node_42881" labelType="html" label="MapPartitionsRDD [42881] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111728 { id="cluster_111728"; isCluster="true"; label="InMemoryTableScan"; 42882 [id="node_42882" labelType="html" label="MapPartitionsRDD [42882] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42883 [id="node_42883" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#860211 AS qty#860213, demandChannel#860206, demandStream#860207, cachedKpis#860212 AS kpis#860214]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#860210L, cachedShardId#860209], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1381587]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1381583]\n : +- *(2) Has... [42883] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111726 { id="cluster_111726"; isCluster="true"; label="Exchange"; 42890 [id="node_42890" labelType="html" label="ShuffledRowRDD [42890] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111723 { id="cluster_111723"; isCluster="true"; label="WholeStageCodegen (4)"; 42891 [id="node_42891" labelType="html" label="MapPartitionsRDD [42891] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111709 { id="cluster_111709"; isCluster="true"; label="WholeStageCodegen (5)"; 42892 [id="node_42892" labelType="html" label="ZippedPartitionsRDD2 [42892] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42893 [id="node_42893" labelType="html" label="MapPartitionsRDD [42893] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111790 { id="cluster_111790"; isCluster="true"; label="InMemoryTableScan"; 42894 [id="node_42894" labelType="html" label="MapPartitionsRDD [42894] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42895 [id="node_42895" labelType="html" label="MapPartitionsRDD [42895] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42896 [id="node_42896" labelType="html" label="MapPartitionsRDD [42896] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111787 { id="cluster_111787"; isCluster="true"; label="WholeStageCodegen (6)"; 42897 [id="node_42897" labelType="html" label="MapPartitionsRDD [42897] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111708 { id="cluster_111708"; isCluster="true"; label="Union"; 42898 [id="node_42898" labelType="html" label="UnionRDD [42898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111707 { id="cluster_111707"; isCluster="true"; label="InMemoryTableScan"; 42899 [id="node_42899" labelType="html" label="MapPartitionsRDD [42899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42900 [id="node_42900" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#860446, null AS demandStream#860447, [] AS kpis#860481, true AS isNewlyCalculated#860449]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#860438, ), isnull(shardId#860438), coalesce(worklistShardItemId#860439L, 0), isnull(worklistShardItemId#860439L), coalesce(version#860440, 0), isnull(version#860440), coalesce(product#860441, ), isnull(product#860441), coalesce(plant#860442, ), isnull(plant#860442), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#860213, 0.0))), isnull(qty#... [42900] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112011 { id="cluster_112011"; isCluster="true"; label="InMemoryTableScan"; 42966 [id="node_42966" labelType="html" label="MapPartitionsRDD [42966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42967 [id="node_42967" labelType="html" label="MapPartitionsRDD [42967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42968 [id="node_42968" labelType="html" label="MapPartitionsRDD [42968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112006 { id="cluster_112006"; isCluster="true"; label="WholeStageCodegen (3)"; 42969 [id="node_42969" labelType="html" label="MapPartitionsRDD [42969] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112005 { id="cluster_112005"; isCluster="true"; label="Exchange"; 42970 [id="node_42970" labelType="html" label="MapPartitionsRDD [42970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42862->42863; 42874->42875; 42878->42879; 42875->42880; 42879->42880; 42880->42881; 42881->42882; 42882->42883; 42890->42891; 42863->42892; 42891->42892; 42892->42893; 42883->42894; 42894->42895; 42895->42896; 42896->42897; 42893->42898; 42897->42898; 42898->42899; 42899->42900; 42900->42966; 42966->42967; 42967->42968; 42968->42969; 42969->42970; }