digraph G { id="graph_96255"; subgraph graph_stage_96255 { id="graph_stage_96255"; isCluster="true"; label="Stage 96255"; 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_114472 { id="cluster_114472"; isCluster="true"; label="Exchange"; 44029 [id="node_44029" labelType="html" label="ShuffledRowRDD [44029] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114471 { id="cluster_114471"; isCluster="true"; label="ObjectHashAggregate"; 44030 [id="node_44030" labelType="html" label="MapPartitionsRDD [44030] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114483 { id="cluster_114483"; isCluster="true"; label="InMemoryTableScan"; 44031 [id="node_44031" labelType="html" label="MapPartitionsRDD [44031] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44032 [id="node_44032" labelType="html" label="MapPartitionsRDD [44032] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44033 [id="node_44033" labelType="html" label="MapPartitionsRDD [44033] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114479 { id="cluster_114479"; isCluster="true"; label="WholeStageCodegen (12)"; 44034 [id="node_44034" labelType="html" label="MapPartitionsRDD [44034] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114470 { id="cluster_114470"; isCluster="true"; label="Union"; 44035 [id="node_44035" labelType="html" label="UnionRDD [44035] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114469 { id="cluster_114469"; isCluster="true"; label="Exchange"; 44036 [id="node_44036" labelType="html" label="MapPartitionsRDD [44036] [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; 44029->44030; 43984->44031; 44031->44032; 44032->44033; 44033->44034; 44030->44035; 44034->44035; 44035->44036; }