digraph G { id="graph_99806"; subgraph graph_stage_99806 { id="graph_stage_99806"; isCluster="true"; label="Stage 99806"; 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_120042 { id="cluster_120042"; isCluster="true"; label="InMemoryTableScan"; 46194 [id="node_46194" labelType="html" label="MapPartitionsRDD [46194] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46195 [id="node_46195" labelType="html" label="MapPartitionsRDD [46195] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46196 [id="node_46196" labelType="html" label="MapPartitionsRDD [46196] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120038 { id="cluster_120038"; isCluster="true"; label="WholeStageCodegen (11)"; 46197 [id="node_46197" labelType="html" label="MapPartitionsRDD [46197] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120037 { id="cluster_120037"; isCluster="true"; label="ObjectHashAggregate"; 46198 [id="node_46198" labelType="html" label="MapPartitionsRDD [46198] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120036 { id="cluster_120036"; isCluster="true"; label="Exchange"; 46199 [id="node_46199" labelType="html" label="MapPartitionsRDD [46199] [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->46194; 46194->46195; 46195->46196; 46196->46197; 46197->46198; 46198->46199; }