digraph G { id="graph_99879"; subgraph graph_stage_99879 { id="graph_stage_99879"; isCluster="true"; label="Stage 99879"; subgraph cluster_119838 { id="cluster_119838"; isCluster="true"; label="Exchange"; 46117 [id="node_46117" labelType="html" label="ShuffledRowRDD [46117] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119835 { id="cluster_119835"; isCluster="true"; label="WholeStageCodegen (1)"; 46118 [id="node_46118" labelType="html" label="MapPartitionsRDD [46118] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119858 { id="cluster_119858"; isCluster="true"; label="Exchange"; 46129 [id="node_46129" labelType="html" label="ShuffledRowRDD [46129] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119855 { id="cluster_119855"; isCluster="true"; label="WholeStageCodegen (4)"; 46130 [id="node_46130" labelType="html" label="MapPartitionsRDD [46130] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119887 { id="cluster_119887"; isCluster="true"; label="Exchange"; 46133 [id="node_46133" labelType="html" label="ShuffledRowRDD [46133] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119884 { id="cluster_119884"; isCluster="true"; label="WholeStageCodegen (6)"; 46134 [id="node_46134" labelType="html" label="MapPartitionsRDD [46134] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119847 { id="cluster_119847"; isCluster="true"; label="WholeStageCodegen (7)"; 46135 [id="node_46135" labelType="html" label="ZippedPartitionsRDD2 [46135] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46136 [id="node_46136" labelType="html" label="MapPartitionsRDD [46136] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119846 { id="cluster_119846"; isCluster="true"; label="InMemoryTableScan"; 46137 [id="node_46137" labelType="html" label="MapPartitionsRDD [46137] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46138 [id="node_46138" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#927239 AS qty#927241, demandChannel#927234, demandStream#927235, cachedKpis#927240 AS kpis#927242]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#927238L, cachedShardId#927237], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1450903]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1450899]\n : +- *(2) Has... [46138] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119844 { id="cluster_119844"; isCluster="true"; label="Exchange"; 46145 [id="node_46145" labelType="html" label="ShuffledRowRDD [46145] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119841 { id="cluster_119841"; isCluster="true"; label="WholeStageCodegen (4)"; 46146 [id="node_46146" labelType="html" label="MapPartitionsRDD [46146] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119827 { id="cluster_119827"; isCluster="true"; label="WholeStageCodegen (5)"; 46147 [id="node_46147" labelType="html" label="ZippedPartitionsRDD2 [46147] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46148 [id="node_46148" labelType="html" label="MapPartitionsRDD [46148] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119908 { id="cluster_119908"; isCluster="true"; label="InMemoryTableScan"; 46149 [id="node_46149" labelType="html" label="MapPartitionsRDD [46149] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46150 [id="node_46150" labelType="html" label="MapPartitionsRDD [46150] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46151 [id="node_46151" labelType="html" label="MapPartitionsRDD [46151] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119905 { id="cluster_119905"; isCluster="true"; label="WholeStageCodegen (6)"; 46152 [id="node_46152" labelType="html" label="MapPartitionsRDD [46152] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119826 { id="cluster_119826"; isCluster="true"; label="Union"; 46153 [id="node_46153" labelType="html" label="UnionRDD [46153] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119825 { id="cluster_119825"; isCluster="true"; label="InMemoryTableScan"; 46154 [id="node_46154" labelType="html" label="MapPartitionsRDD [46154] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46155 [id="node_46155" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#927474, null AS demandStream#927475, [] AS kpis#927509, true AS isNewlyCalculated#927477]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#927466, ), isnull(shardId#927466), coalesce(worklistShardItemId#927467L, 0), isnull(worklistShardItemId#927467L), coalesce(version#927468, 0), isnull(version#927468), coalesce(product#927469, ), isnull(product#927469), coalesce(plant#927470, ), isnull(plant#927470), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#927241, 0.0))), isnull(qty#... [46155] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120258 { id="cluster_120258"; isCluster="true"; label="InMemoryTableScan"; 46285 [id="node_46285" labelType="html" label="MapPartitionsRDD [46285] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46286 [id="node_46286" labelType="html" label="MapPartitionsRDD [46286] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46287 [id="node_46287" labelType="html" label="MapPartitionsRDD [46287] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120254 { id="cluster_120254"; isCluster="true"; label="WholeStageCodegen (3)"; 46288 [id="node_46288" labelType="html" label="MapPartitionsRDD [46288] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120253 { id="cluster_120253"; isCluster="true"; label="Exchange"; 46289 [id="node_46289" labelType="html" label="MapPartitionsRDD [46289] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46117->46118; 46129->46130; 46133->46134; 46130->46135; 46134->46135; 46135->46136; 46136->46137; 46137->46138; 46145->46146; 46118->46147; 46146->46147; 46147->46148; 46138->46149; 46149->46150; 46150->46151; 46151->46152; 46148->46153; 46152->46153; 46153->46154; 46154->46155; 46155->46285; 46285->46286; 46286->46287; 46287->46288; 46288->46289; }