digraph G { id="graph_96507"; subgraph graph_stage_96507 { id="graph_stage_96507"; isCluster="true"; label="Stage 96507"; subgraph cluster_114274 { id="cluster_114274"; isCluster="true"; label="Exchange"; 43946 [id="node_43946" labelType="html" label="ShuffledRowRDD [43946] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114271 { id="cluster_114271"; isCluster="true"; label="WholeStageCodegen (1)"; 43947 [id="node_43947" labelType="html" label="MapPartitionsRDD [43947] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114294 { id="cluster_114294"; isCluster="true"; label="Exchange"; 43958 [id="node_43958" labelType="html" label="ShuffledRowRDD [43958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114291 { id="cluster_114291"; isCluster="true"; label="WholeStageCodegen (4)"; 43959 [id="node_43959" labelType="html" label="MapPartitionsRDD [43959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114329 { id="cluster_114329"; isCluster="true"; label="Exchange"; 43962 [id="node_43962" labelType="html" label="ShuffledRowRDD [43962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114326 { id="cluster_114326"; isCluster="true"; label="WholeStageCodegen (6)"; 43963 [id="node_43963" labelType="html" label="MapPartitionsRDD [43963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114283 { id="cluster_114283"; isCluster="true"; label="WholeStageCodegen (7)"; 43964 [id="node_43964" labelType="html" label="ZippedPartitionsRDD2 [43964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43965 [id="node_43965" labelType="html" label="MapPartitionsRDD [43965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114282 { id="cluster_114282"; isCluster="true"; label="InMemoryTableScan"; 43966 [id="node_43966" labelType="html" label="MapPartitionsRDD [43966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43967 [id="node_43967" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#882764 AS qty#882766, demandChannel#882759, demandStream#882760, cachedKpis#882765 AS kpis#882767]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#882763L, cachedShardId#882762], 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=1388014]\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=1388010]\n : +- *(2) Has... [43967] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114280 { id="cluster_114280"; isCluster="true"; label="Exchange"; 43974 [id="node_43974" labelType="html" label="ShuffledRowRDD [43974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114277 { id="cluster_114277"; isCluster="true"; label="WholeStageCodegen (4)"; 43975 [id="node_43975" labelType="html" label="MapPartitionsRDD [43975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114263 { id="cluster_114263"; isCluster="true"; label="WholeStageCodegen (5)"; 43976 [id="node_43976" labelType="html" label="ZippedPartitionsRDD2 [43976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43977 [id="node_43977" labelType="html" label="MapPartitionsRDD [43977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114344 { id="cluster_114344"; isCluster="true"; label="InMemoryTableScan"; 43978 [id="node_43978" labelType="html" label="MapPartitionsRDD [43978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43979 [id="node_43979" labelType="html" label="MapPartitionsRDD [43979] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43980 [id="node_43980" labelType="html" label="MapPartitionsRDD [43980] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114341 { id="cluster_114341"; isCluster="true"; label="WholeStageCodegen (6)"; 43981 [id="node_43981" labelType="html" label="MapPartitionsRDD [43981] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114262 { id="cluster_114262"; isCluster="true"; label="Union"; 43982 [id="node_43982" labelType="html" label="UnionRDD [43982] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114261 { id="cluster_114261"; isCluster="true"; label="InMemoryTableScan"; 43983 [id="node_43983" labelType="html" label="MapPartitionsRDD [43983] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43984 [id="node_43984" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#882999, null AS demandStream#883000, [] AS kpis#883034, true AS isNewlyCalculated#883002]\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#882991, ), isnull(shardId#882991), coalesce(worklistShardItemId#882992L, 0), isnull(worklistShardItemId#882992L), coalesce(version#882993, 0), isnull(version#882993), coalesce(product#882994, ), isnull(product#882994), coalesce(plant#882995, ), isnull(plant#882995), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#882766, 0.0))), isnull(qty#... [43984] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114694 { id="cluster_114694"; isCluster="true"; label="InMemoryTableScan"; 44114 [id="node_44114" labelType="html" label="MapPartitionsRDD [44114] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44115 [id="node_44115" labelType="html" label="MapPartitionsRDD [44115] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44116 [id="node_44116" labelType="html" label="MapPartitionsRDD [44116] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114690 { id="cluster_114690"; isCluster="true"; label="WholeStageCodegen (3)"; 44117 [id="node_44117" labelType="html" label="MapPartitionsRDD [44117] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114689 { id="cluster_114689"; isCluster="true"; label="Exchange"; 44118 [id="node_44118" labelType="html" label="MapPartitionsRDD [44118] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43946->43947; 43958->43959; 43962->43963; 43959->43964; 43963->43964; 43964->43965; 43965->43966; 43966->43967; 43974->43975; 43947->43976; 43975->43976; 43976->43977; 43967->43978; 43978->43979; 43979->43980; 43980->43981; 43977->43982; 43981->43982; 43982->43983; 43983->43984; 43984->44114; 44114->44115; 44115->44116; 44116->44117; 44117->44118; }