digraph G { id="graph_91191"; subgraph graph_stage_91191 { id="graph_stage_91191"; isCluster="true"; label="Stage 91191"; subgraph cluster_109857 { id="cluster_109857"; isCluster="true"; label="Exchange"; 42070 [id="node_42070" labelType="html" label="ShuffledRowRDD [42070] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109854 { id="cluster_109854"; isCluster="true"; label="WholeStageCodegen (1)"; 42071 [id="node_42071" labelType="html" label="MapPartitionsRDD [42071] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109877 { id="cluster_109877"; isCluster="true"; label="Exchange"; 42082 [id="node_42082" labelType="html" label="ShuffledRowRDD [42082] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109874 { id="cluster_109874"; isCluster="true"; label="WholeStageCodegen (4)"; 42083 [id="node_42083" labelType="html" label="MapPartitionsRDD [42083] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109906 { id="cluster_109906"; isCluster="true"; label="Exchange"; 42086 [id="node_42086" labelType="html" label="ShuffledRowRDD [42086] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109903 { id="cluster_109903"; isCluster="true"; label="WholeStageCodegen (6)"; 42087 [id="node_42087" labelType="html" label="MapPartitionsRDD [42087] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109866 { id="cluster_109866"; isCluster="true"; label="WholeStageCodegen (7)"; 42088 [id="node_42088" labelType="html" label="ZippedPartitionsRDD2 [42088] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42089 [id="node_42089" labelType="html" label="MapPartitionsRDD [42089] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109865 { id="cluster_109865"; isCluster="true"; label="InMemoryTableScan"; 42090 [id="node_42090" labelType="html" label="MapPartitionsRDD [42090] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42091 [id="node_42091" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#843537 AS qty#843539, demandChannel#843532, demandStream#843533, cachedKpis#843538 AS kpis#843540]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#843536L, cachedShardId#843535], 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=1376847]\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=1376843]\n : +- *(2) Has... [42091] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109863 { id="cluster_109863"; isCluster="true"; label="Exchange"; 42098 [id="node_42098" labelType="html" label="ShuffledRowRDD [42098] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109860 { id="cluster_109860"; isCluster="true"; label="WholeStageCodegen (4)"; 42099 [id="node_42099" labelType="html" label="MapPartitionsRDD [42099] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109846 { id="cluster_109846"; isCluster="true"; label="WholeStageCodegen (5)"; 42100 [id="node_42100" labelType="html" label="ZippedPartitionsRDD2 [42100] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42101 [id="node_42101" labelType="html" label="MapPartitionsRDD [42101] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109921 { id="cluster_109921"; isCluster="true"; label="InMemoryTableScan"; 42102 [id="node_42102" labelType="html" label="MapPartitionsRDD [42102] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42103 [id="node_42103" labelType="html" label="MapPartitionsRDD [42103] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42104 [id="node_42104" labelType="html" label="MapPartitionsRDD [42104] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109918 { id="cluster_109918"; isCluster="true"; label="WholeStageCodegen (6)"; 42105 [id="node_42105" labelType="html" label="MapPartitionsRDD [42105] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109845 { id="cluster_109845"; isCluster="true"; label="Union"; 42106 [id="node_42106" labelType="html" label="UnionRDD [42106] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109844 { id="cluster_109844"; isCluster="true"; label="InMemoryTableScan"; 42107 [id="node_42107" labelType="html" label="MapPartitionsRDD [42107] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42108 [id="node_42108" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#843772, null AS demandStream#843773, [] AS kpis#843807, true AS isNewlyCalculated#843775]\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#843764, ), isnull(shardId#843764), coalesce(worklistShardItemId#843765L, 0), isnull(worklistShardItemId#843765L), coalesce(version#843766, 0), isnull(version#843766), coalesce(product#843767, ), isnull(product#843767), coalesce(plant#843768, ), isnull(plant#843768), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#843539, 0.0))), isnull(qty#... [42108] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110277 { id="cluster_110277"; isCluster="true"; label="InMemoryTableScan"; 42238 [id="node_42238" labelType="html" label="MapPartitionsRDD [42238] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42239 [id="node_42239" labelType="html" label="MapPartitionsRDD [42239] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42240 [id="node_42240" labelType="html" label="MapPartitionsRDD [42240] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110273 { id="cluster_110273"; isCluster="true"; label="WholeStageCodegen (3)"; 42241 [id="node_42241" labelType="html" label="MapPartitionsRDD [42241] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110272 { id="cluster_110272"; isCluster="true"; label="Exchange"; 42242 [id="node_42242" labelType="html" label="MapPartitionsRDD [42242] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42070->42071; 42082->42083; 42086->42087; 42083->42088; 42087->42088; 42088->42089; 42089->42090; 42090->42091; 42098->42099; 42071->42100; 42099->42100; 42100->42101; 42091->42102; 42102->42103; 42103->42104; 42104->42105; 42101->42106; 42105->42106; 42106->42107; 42107->42108; 42108->42238; 42238->42239; 42239->42240; 42240->42241; 42241->42242; }