Class PlannerSettings
java.lang.Object
org.apache.drill.exec.planner.physical.PlannerSettings
- All Implemented Interfaces:
org.apache.calcite.plan.Context
,org.apache.calcite.schema.Wrapper
-
Field Summary
Modifier and TypeFieldDescriptionstatic final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final int
static final OptionValidator
static final String
static final TypeValidators.BooleanValidator
static final TypeValidators.BooleanValidator
static final String
static final String
static final String
static final TypeValidators.BooleanValidator
static final String
static final TypeValidators.BooleanValidator
static final String
static final OptionValidator
static final TypeValidators.DoubleValidator
static final TypeValidators.DoubleValidator
static final TypeValidators.BooleanValidator
static final String
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final TypeValidators.LongValidator
static final TypeValidators.RangeDoubleValidator
static final TypeValidators.BooleanValidator
static final TypeValidators.RangeLongValidator
static final TypeValidators.RangeLongValidator
static final TypeValidators.RangeDoubleValidator
static final TypeValidators.BooleanValidator
static final TypeValidators.BooleanValidator
static final TypeValidators.RangeDoubleValidator
static final TypeValidators.RangeDoubleValidator
static final TypeValidators.BooleanValidator
static final TypeValidators.BooleanValidator
static final OptionValidator
static final int
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final TypeValidators.BooleanValidator
static final String
static final TypeValidators.LongValidator
static final String
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final OptionValidator
static final TypeValidators.EnumeratedStringValidator
static final String
static final OptionValidator
static final TypeValidators.RangeDoubleValidator
static final OptionValidator
static final OptionValidator
static final TypeValidators.RangeDoubleValidator
static final TypeValidators.BooleanValidator
static final OptionValidator
static final OptionValidator
static final TypeValidators.BooleanValidator
static final String
static final TypeValidators.BooleanValidator
static final String
static final TypeValidators.BooleanValidator
static final String
-
Constructor Summary
ConstructorDescriptionPlannerSettings
(OptionManager options, FunctionImplementationRegistry functionImplementationRegistry, String queryUser, AliasRegistryProvider aliasRegistryProvider) -
Method Summary
Modifier and TypeMethodDescriptionvoid
double
long
double
double
double
long
double
long
double
double
double
static long
long
long
double
long
long
org.apache.calcite.avatica.util.Quoting
double
double
long
double
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
int
void
setNumEndPoints
(int numEndPoints) void
setUseDefaultCosting
(boolean defcost) <T> T
boolean
boolean
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.calcite.schema.Wrapper
maybeUnwrap, unwrapOrThrow
-
Field Details
-
MAX_BROADCAST_THRESHOLD
public static final int MAX_BROADCAST_THRESHOLD- See Also:
-
DEFAULT_IDENTIFIER_MAX_LENGTH
public static final int DEFAULT_IDENTIFIER_MAX_LENGTH- See Also:
-
CONSTANT_FOLDING
-
DISABLE_EXCHANGE_OPTION
- See Also:
-
EXCHANGE
-
ENABLE_HASH_AGG_OPTION
- See Also:
-
HASHAGG
-
ENABLE_STREAM_AGG_OPTION
- See Also:
-
STREAMAGG
-
TOPN
-
ENABLE_HASH_JOIN_OPTION
- See Also:
-
HASHJOIN
-
SEMIJOIN
-
MERGEJOIN
-
NESTEDLOOPJOIN
-
MULTIPHASE
-
BROADCAST
-
BROADCAST_THRESHOLD
-
BROADCAST_FACTOR
-
NESTEDLOOPJOIN_FACTOR
-
NLJOIN_FOR_SCALAR
-
JOIN_ROW_COUNT_ESTIMATE_FACTOR
-
MUX_EXCHANGE
-
ORDERED_MUX_EXCHANGE
-
DEMUX_EXCHANGE
-
PARTITION_SENDER_THREADS_FACTOR
-
PARTITION_SENDER_MAX_THREADS
-
PARTITION_SENDER_SET_THREADS
-
PRODUCER_CONSUMER
-
PRODUCER_CONSUMER_QUEUE_SIZE
-
HASH_SINGLE_KEY
-
HASH_JOIN_SWAP
-
HASH_JOIN_SWAP_MARGIN_FACTOR
-
ENABLE_DECIMAL_DATA_TYPE_KEY
- See Also:
-
ENABLE_DECIMAL_DATA_TYPE
-
HEP_OPT
-
HEP_PARTITION_PRUNING
-
ROWKEYJOIN_CONVERSION
-
ROWKEYJOIN_CONVERSION_SELECTIVITY_THRESHOLD
-
ROWKEYJOIN_CONVERSION_USING_HASHJOIN
-
PLANNER_MEMORY_LIMIT
-
UNIONALL_DISTRIBUTE_KEY
- See Also:
-
UNIONALL_DISTRIBUTE
-
USE_SIMPLE_OPTIMIZER_KEY
- See Also:
-
USE_SIMPLE_OPTIMIZER
-
INDEX_PLANNING
-
ENABLE_STATS
-
DISABLE_FULL_TABLE_SCAN
-
INDEX_MAX_CHOSEN_INDEXES_PER_TABLE
-
INDEX_FORCE_SORT_NONCOVERING
-
INDEX_USE_HASHJOIN_NONCOVERING
-
INDEX_COVERING_SELECTIVITY_THRESHOLD
-
INDEX_NONCOVERING_SELECTIVITY_THRESHOLD
-
INDEX_ROWKEYJOIN_COST_FACTOR
-
INDEX_PREFER_INTERSECT_PLANS
-
INDEX_MAX_INDEXES_TO_INTERSECT
-
INDEX_STATS_ROWCOUNT_SCALING_FACTOR
-
IDENTIFIER_MAX_LENGTH
-
FILTER_MIN_SELECTIVITY_ESTIMATE_FACTOR
-
FILTER_MAX_SELECTIVITY_ESTIMATE_FACTOR
-
TYPE_INFERENCE_KEY
- See Also:
-
TYPE_INFERENCE
-
IN_SUBQUERY_THRESHOLD
-
PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_KEY
- See Also:
-
PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING
-
PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD_KEY
- See Also:
-
PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD
public static final TypeValidators.LongValidator PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD -
QUOTING_IDENTIFIERS_KEY
- See Also:
-
QUOTING_IDENTIFIERS
-
ENABLE_UNNEST_LATERAL_KEY
- See Also:
-
ENABLE_UNNEST_LATERAL
-
JOIN_OPTIMIZATION
-
FORCE_2PHASE_AGGR_KEY
- See Also:
-
FORCE_2PHASE_AGGR
-
STATISTICS_USE
-
STATISTICS_MULTICOL_NDV_ADJUST_FACTOR
-
options
-
functionImplementationRegistry
-
-
Constructor Details
-
PlannerSettings
public PlannerSettings(OptionManager options, FunctionImplementationRegistry functionImplementationRegistry, String queryUser, AliasRegistryProvider aliasRegistryProvider)
-
-
Method Details
-
getOptions
-
isSingleMode
public boolean isSingleMode() -
forceSingleMode
public void forceSingleMode() -
numEndPoints
public int numEndPoints() -
getRowCountEstimateFactor
public double getRowCountEstimateFactor() -
getBroadcastFactor
public double getBroadcastFactor() -
getNestedLoopJoinFactor
public double getNestedLoopJoinFactor() -
isNlJoinForScalarOnly
public boolean isNlJoinForScalarOnly() -
useDefaultCosting
public boolean useDefaultCosting() -
setNumEndPoints
public void setNumEndPoints(int numEndPoints) -
setUseDefaultCosting
public void setUseDefaultCosting(boolean defcost) -
isHashAggEnabled
public boolean isHashAggEnabled() -
isConstantFoldingEnabled
public boolean isConstantFoldingEnabled() -
isStreamAggEnabled
public boolean isStreamAggEnabled() -
isHashJoinEnabled
public boolean isHashJoinEnabled() -
isSemiJoinEnabled
public boolean isSemiJoinEnabled() -
isMergeJoinEnabled
public boolean isMergeJoinEnabled() -
isNestedLoopJoinEnabled
public boolean isNestedLoopJoinEnabled() -
isMultiPhaseAggEnabled
public boolean isMultiPhaseAggEnabled() -
isBroadcastJoinEnabled
public boolean isBroadcastJoinEnabled() -
isHashSingleKey
public boolean isHashSingleKey() -
isHashJoinSwapEnabled
public boolean isHashJoinSwapEnabled() -
isHepPartitionPruningEnabled
public boolean isHepPartitionPruningEnabled() -
isRowKeyJoinConversionEnabled
public boolean isRowKeyJoinConversionEnabled() -
isRowKeyJoinConversionUsingHashJoin
public boolean isRowKeyJoinConversionUsingHashJoin() -
getRowKeyJoinConversionSelThreshold
public double getRowKeyJoinConversionSelThreshold() -
isHepOptEnabled
public boolean isHepOptEnabled() -
getHashJoinSwapMarginFactor
public double getHashJoinSwapMarginFactor() -
getBroadcastThreshold
public long getBroadcastThreshold() -
getSliceTarget
public long getSliceTarget() -
isMemoryEstimationEnabled
public boolean isMemoryEstimationEnabled() -
getFsPartitionColumnLabel
-
getIdentifierMaxLength
public long getIdentifierMaxLength() -
getPlanningMemoryLimit
public long getPlanningMemoryLimit() -
getQueryUser
-
getAliasRegistryProvider
-
getInitialPlanningMemorySize
public static long getInitialPlanningMemorySize() -
getFilterMinSelectivityEstimateFactor
public double getFilterMinSelectivityEstimateFactor() -
getFilterMaxSelectivityEstimateFactor
public double getFilterMaxSelectivityEstimateFactor() -
isTypeInferenceEnabled
public boolean isTypeInferenceEnabled() -
isForce2phaseAggr
public boolean isForce2phaseAggr() -
getInSubqueryThreshold
public long getInSubqueryThreshold() -
isUnionAllDistributeEnabled
public boolean isUnionAllDistributeEnabled() -
isParquetRowGroupFilterPushdownPlanningEnabled
public boolean isParquetRowGroupFilterPushdownPlanningEnabled() -
getParquetRowGroupFilterPushDownThreshold
public long getParquetRowGroupFilterPushDownThreshold() -
getQuotingIdentifiers
public org.apache.calcite.avatica.util.Quoting getQuotingIdentifiers()- Returns:
- Quoting enum for current quoting identifiers character
-
isJoinOptimizationEnabled
public boolean isJoinOptimizationEnabled() -
isUnnestLateralEnabled
public boolean isUnnestLateralEnabled() -
isIndexPlanningEnabled
public boolean isIndexPlanningEnabled() -
isStatisticsEnabled
public boolean isStatisticsEnabled() -
isDisableFullTableScan
public boolean isDisableFullTableScan() -
getIndexMaxChosenIndexesPerTable
public long getIndexMaxChosenIndexesPerTable() -
isIndexForceSortNonCovering
public boolean isIndexForceSortNonCovering() -
isIndexUseHashJoinNonCovering
public boolean isIndexUseHashJoinNonCovering() -
getIndexCoveringSelThreshold
public double getIndexCoveringSelThreshold() -
getIndexNonCoveringSelThreshold
public double getIndexNonCoveringSelThreshold() -
getIndexRowKeyJoinCostFactor
public double getIndexRowKeyJoinCostFactor() -
isIndexIntersectPlanPreferred
public boolean isIndexIntersectPlanPreferred() -
getMaxIndexesToIntersect
public long getMaxIndexesToIntersect() -
getIndexStatsRowCountScalingFactor
public double getIndexStatsRowCountScalingFactor() -
useStatistics
public boolean useStatistics() -
getStatisticsMultiColNdvAdjustmentFactor
public double getStatisticsMultiColNdvAdjustmentFactor() -
unwrap
- Specified by:
unwrap
in interfaceorg.apache.calcite.schema.Wrapper
-