Use static imports in AddExchanges
package com.facebook.presto.sql.planner.optimizations;
import com.facebook.presto.Session;
-import com.facebook.presto.SystemSessionProperties;
import com.facebook.presto.execution.warnings.WarningCollector;
import com.facebook.presto.metadata.Metadata;
import com.facebook.presto.spi.GroupingProperty;
@@ -89,8 +88,12 @@ import java.util.Set;
import java.util.function.Function;
import static com.facebook.presto.SystemSessionProperties.isColocatedJoinEnabled;
+import static com.facebook.presto.SystemSessionProperties.isDistributedIndexJoinEnabled;
import static com.facebook.presto.SystemSessionProperties.isDistributedSortEnabled;
import static com.facebook.presto.SystemSessionProperties.isForceSingleNodeOutput;
+import static com.facebook.presto.SystemSessionProperties.isRedistributeWrites;
+import static com.facebook.presto.SystemSessionProperties.isScaleWriters;
+import static com.facebook.presto.SystemSessionProperties.preferStreamingOperators;
import static com.facebook.presto.sql.planner.FragmentTableScanCounter.countSources;
import static com.facebook.presto.sql.planner.FragmentTableScanCounter.hasMultipleSources;
import static com.facebook.presto.sql.planner.SystemPartitioningHandle.FIXED_ARBITRARY_DISTRIBUTION;
@@ -156,10 +159,10 @@ public class AddExchanges
this.symbolAllocator = symbolAllocator;
this.types = symbolAllocator.getTypes();
this.session = session;
- this.distributedIndexJoins = SystemSessionProperties.isDistributedIndexJoinEnabled(session);
- this.redistributeWrites = SystemSessionProperties.isRedistributeWrites(session);
- this.scaleWriters = SystemSessionProperties.isScaleWriters(session);
- this.preferStreamingOperators = SystemSessionProperties.preferStreamingOperators(session);
+ this.distributedIndexJoins = isDistributedIndexJoinEnabled(session);
+ this.redistributeWrites = isRedistributeWrites(session);
+ this.scaleWriters = isScaleWriters(session);
+ this.preferStreamingOperators = preferStreamingOperators(session);
}
@Override
