Remove unused field from FragmentProperties
@@ -331,7 +331,6 @@ public class PlanFragmenter
private final PartitioningScheme partitioningScheme;
private Optional<PartitioningHandle> partitioningHandle = Optional.empty();
- private boolean needPartitioningHandleReassignment;
private final Set<PlanNodeId> partitionedSources = new HashSet<>();
public FragmentProperties(PartitioningScheme partitioningScheme)
@@ -390,7 +389,6 @@ public class PlanFragmenter
Optional<PartitioningHandle> commonPartitioning = metadata.getCommonPartitioning(session, currentPartitioning, distribution);
if (commonPartitioning.isPresent()) {
- needPartitioningHandleReassignment = true;
partitioningHandle = commonPartitioning;
return this;
}
@@ -456,7 +454,6 @@ public class PlanFragmenter
Optional<PartitioningHandle> commonPartitioning = metadata.getCommonPartitioning(session, currentPartitioning, distribution);
if (commonPartitioning.isPresent()) {
- needPartitioningHandleReassignment = true;
partitioningHandle = commonPartitioning;
return this;
}
@@ -483,11 +480,6 @@ public class PlanFragmenter
return partitioningHandle.get();
}
- public boolean isNeedPartitioningHandleReassignment()
- {
- return needPartitioningHandleReassignment;
- }
-
public Set<PlanNodeId> getPartitionedSources()
{
return partitionedSources;
