org.apache.drill.exec.planner.physical

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

public class PlannerSettings
extends Object
implements org.apache.calcite.plan.Context

Field Summary

Fields

Modifier and Type	Field and Description
static OptionValidator	BROADCAST
static OptionValidator	BROADCAST_FACTOR
static OptionValidator	BROADCAST_THRESHOLD
static OptionValidator	CONSTANT_FOLDING
static int	DEFAULT_IDENTIFIER_MAX_LENGTH
static OptionValidator	DEMUX_EXCHANGE
static String	DISABLE_EXCHANGE_OPTION
static TypeValidators.BooleanValidator	DISABLE_FULL_TABLE_SCAN
static TypeValidators.BooleanValidator	ENABLE_DECIMAL_DATA_TYPE
static String	ENABLE_DECIMAL_DATA_TYPE_KEY
static String	ENABLE_HASH_AGG_OPTION
static String	ENABLE_HASH_JOIN_OPTION
static TypeValidators.BooleanValidator	ENABLE_STATS
static String	ENABLE_STREAM_AGG_OPTION
static TypeValidators.BooleanValidator	ENABLE_UNNEST_LATERAL
static String	ENABLE_UNNEST_LATERAL_KEY
static OptionValidator	EXCHANGE
static TypeValidators.DoubleValidator	FILTER_MAX_SELECTIVITY_ESTIMATE_FACTOR
static TypeValidators.DoubleValidator	FILTER_MIN_SELECTIVITY_ESTIMATE_FACTOR
static TypeValidators.BooleanValidator	FORCE_2PHASE_AGGR
static String	FORCE_2PHASE_AGGR_KEY
FunctionImplementationRegistry	functionImplementationRegistry
static OptionValidator	HASH_JOIN_SWAP
static OptionValidator	HASH_JOIN_SWAP_MARGIN_FACTOR
static OptionValidator	HASH_SINGLE_KEY
static OptionValidator	HASHAGG
static OptionValidator	HASHJOIN
static OptionValidator	HEP_OPT
static OptionValidator	HEP_PARTITION_PRUNING
static OptionValidator	IDENTIFIER_MAX_LENGTH
static TypeValidators.LongValidator	IN_SUBQUERY_THRESHOLD
static TypeValidators.RangeDoubleValidator	INDEX_COVERING_SELECTIVITY_THRESHOLD
static TypeValidators.BooleanValidator	INDEX_FORCE_SORT_NONCOVERING
static TypeValidators.RangeLongValidator	INDEX_MAX_CHOSEN_INDEXES_PER_TABLE
static TypeValidators.RangeLongValidator	INDEX_MAX_INDEXES_TO_INTERSECT
static TypeValidators.RangeDoubleValidator	INDEX_NONCOVERING_SELECTIVITY_THRESHOLD
static TypeValidators.BooleanValidator	INDEX_PLANNING
static TypeValidators.BooleanValidator	INDEX_PREFER_INTERSECT_PLANS
static TypeValidators.RangeDoubleValidator	INDEX_ROWKEYJOIN_COST_FACTOR
static TypeValidators.RangeDoubleValidator	INDEX_STATS_ROWCOUNT_SCALING_FACTOR
static TypeValidators.BooleanValidator	INDEX_USE_HASHJOIN_NONCOVERING
static TypeValidators.BooleanValidator	JOIN_OPTIMIZATION
static OptionValidator	JOIN_ROW_COUNT_ESTIMATE_FACTOR
static int	MAX_BROADCAST_THRESHOLD
static OptionValidator	MERGEJOIN
static OptionValidator	MULTIPHASE
static OptionValidator	MUX_EXCHANGE
static OptionValidator	NESTEDLOOPJOIN
static OptionValidator	NESTEDLOOPJOIN_FACTOR
static OptionValidator	NLJOIN_FOR_SCALAR
OptionManager	options
static OptionValidator	ORDERED_MUX_EXCHANGE
static TypeValidators.BooleanValidator	PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING
static String	PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_KEY
static TypeValidators.LongValidator	PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD
static String	PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD_KEY
static OptionValidator	PARTITION_SENDER_MAX_THREADS
static OptionValidator	PARTITION_SENDER_SET_THREADS
static OptionValidator	PARTITION_SENDER_THREADS_FACTOR
static OptionValidator	PLANNER_MEMORY_LIMIT
static OptionValidator	PRODUCER_CONSUMER
static OptionValidator	PRODUCER_CONSUMER_QUEUE_SIZE
static TypeValidators.EnumeratedStringValidator	QUOTING_IDENTIFIERS
static String	QUOTING_IDENTIFIERS_KEY
static OptionValidator	ROWKEYJOIN_CONVERSION
static TypeValidators.RangeDoubleValidator	ROWKEYJOIN_CONVERSION_SELECTIVITY_THRESHOLD
static OptionValidator	ROWKEYJOIN_CONVERSION_USING_HASHJOIN
static OptionValidator	SEMIJOIN
static TypeValidators.RangeDoubleValidator	STATISTICS_MULTICOL_NDV_ADJUST_FACTOR
static TypeValidators.BooleanValidator	STATISTICS_USE
static OptionValidator	STREAMAGG
static OptionValidator	TOPN
static TypeValidators.BooleanValidator	TYPE_INFERENCE
static String	TYPE_INFERENCE_KEY
static TypeValidators.BooleanValidator	UNIONALL_DISTRIBUTE
static String	UNIONALL_DISTRIBUTE_KEY
static TypeValidators.BooleanValidator	USE_SIMPLE_OPTIMIZER
static String	USE_SIMPLE_OPTIMIZER_KEY

Constructor Summary

Constructors

Constructor and Description
PlannerSettings(OptionManager options, FunctionImplementationRegistry functionImplementationRegistry)

Method Summary

Modifier and Type	Method and Description
void	forceSingleMode()
double	getBroadcastFactor()
long	getBroadcastThreshold()
double	getFilterMaxSelectivityEstimateFactor()
double	getFilterMinSelectivityEstimateFactor()
String	getFsPartitionColumnLabel()
double	getHashJoinSwapMarginFactor()
long	getIdentifierMaxLength()
double	getIndexCoveringSelThreshold()
long	getIndexMaxChosenIndexesPerTable()
double	getIndexNonCoveringSelThreshold()
double	getIndexRowKeyJoinCostFactor()
double	getIndexStatsRowCountScalingFactor()
static long	getInitialPlanningMemorySize()
long	getInSubqueryThreshold()
long	getMaxIndexesToIntersect()
double	getNestedLoopJoinFactor()
OptionManager	getOptions()
long	getParquetRowGroupFilterPushDownThreshold()
long	getPlanningMemoryLimit()
org.apache.calcite.avatica.util.Quoting	getQuotingIdentifiers()
double	getRowCountEstimateFactor()
double	getRowKeyJoinConversionSelThreshold()
long	getSliceTarget()
double	getStatisticsMultiColNdvAdjustmentFactor()
boolean	isBroadcastJoinEnabled()
boolean	isConstantFoldingEnabled()
boolean	isDisableFullTableScan()
boolean	isForce2phaseAggr()
boolean	isHashAggEnabled()
boolean	isHashJoinEnabled()
boolean	isHashJoinSwapEnabled()
boolean	isHashSingleKey()
boolean	isHepOptEnabled()
boolean	isHepPartitionPruningEnabled()
boolean	isIndexForceSortNonCovering()
boolean	isIndexIntersectPlanPreferred()
boolean	isIndexPlanningEnabled()
boolean	isIndexUseHashJoinNonCovering()
boolean	isJoinOptimizationEnabled()
boolean	isMemoryEstimationEnabled()
boolean	isMergeJoinEnabled()
boolean	isMultiPhaseAggEnabled()
boolean	isNestedLoopJoinEnabled()
boolean	isNlJoinForScalarOnly()
boolean	isParquetRowGroupFilterPushdownPlanningEnabled()
boolean	isRowKeyJoinConversionEnabled()
boolean	isRowKeyJoinConversionUsingHashJoin()
boolean	isSemiJoinEnabled()
boolean	isSingleMode()
boolean	isStatisticsEnabled()
boolean	isStreamAggEnabled()
boolean	isTypeInferenceEnabled()
boolean	isUnionAllDistributeEnabled()
boolean	isUnnestLateralEnabled()
int	numEndPoints()
void	setNumEndPoints(int numEndPoints)
void	setUseDefaultCosting(boolean defcost)
<T> T	unwrap(Class<T> clazz)
boolean	useDefaultCosting()
boolean	useStatistics()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_BROADCAST_THRESHOLD

public static final int MAX_BROADCAST_THRESHOLD

See Also:

Constant Field Values

DEFAULT_IDENTIFIER_MAX_LENGTH

public static final int DEFAULT_IDENTIFIER_MAX_LENGTH

See Also:

Constant Field Values

CONSTANT_FOLDING

public static final OptionValidator CONSTANT_FOLDING

DISABLE_EXCHANGE_OPTION

public static final String DISABLE_EXCHANGE_OPTION

See Also:

Constant Field Values

EXCHANGE

public static final OptionValidator EXCHANGE

ENABLE_HASH_AGG_OPTION

public static final String ENABLE_HASH_AGG_OPTION

See Also:

Constant Field Values

HASHAGG

public static final OptionValidator HASHAGG

ENABLE_STREAM_AGG_OPTION

public static final String ENABLE_STREAM_AGG_OPTION

See Also:

Constant Field Values

STREAMAGG

public static final OptionValidator STREAMAGG

TOPN

public static final OptionValidator TOPN

ENABLE_HASH_JOIN_OPTION

public static final String ENABLE_HASH_JOIN_OPTION

See Also:

Constant Field Values

HASHJOIN

public static final OptionValidator HASHJOIN

SEMIJOIN

public static final OptionValidator SEMIJOIN

MERGEJOIN

public static final OptionValidator MERGEJOIN

NESTEDLOOPJOIN

public static final OptionValidator NESTEDLOOPJOIN

MULTIPHASE

public static final OptionValidator MULTIPHASE

BROADCAST

public static final OptionValidator BROADCAST

BROADCAST_THRESHOLD

public static final OptionValidator BROADCAST_THRESHOLD

BROADCAST_FACTOR

public static final OptionValidator BROADCAST_FACTOR

NESTEDLOOPJOIN_FACTOR

public static final OptionValidator NESTEDLOOPJOIN_FACTOR

NLJOIN_FOR_SCALAR

public static final OptionValidator NLJOIN_FOR_SCALAR

JOIN_ROW_COUNT_ESTIMATE_FACTOR

public static final OptionValidator JOIN_ROW_COUNT_ESTIMATE_FACTOR

MUX_EXCHANGE

public static final OptionValidator MUX_EXCHANGE

ORDERED_MUX_EXCHANGE

public static final OptionValidator ORDERED_MUX_EXCHANGE

DEMUX_EXCHANGE

public static final OptionValidator DEMUX_EXCHANGE

PARTITION_SENDER_THREADS_FACTOR

public static final OptionValidator PARTITION_SENDER_THREADS_FACTOR

PARTITION_SENDER_MAX_THREADS

public static final OptionValidator PARTITION_SENDER_MAX_THREADS

PARTITION_SENDER_SET_THREADS

public static final OptionValidator PARTITION_SENDER_SET_THREADS

PRODUCER_CONSUMER

public static final OptionValidator PRODUCER_CONSUMER

PRODUCER_CONSUMER_QUEUE_SIZE

public static final OptionValidator PRODUCER_CONSUMER_QUEUE_SIZE

HASH_SINGLE_KEY

public static final OptionValidator HASH_SINGLE_KEY

HASH_JOIN_SWAP

public static final OptionValidator HASH_JOIN_SWAP

HASH_JOIN_SWAP_MARGIN_FACTOR

public static final OptionValidator HASH_JOIN_SWAP_MARGIN_FACTOR

ENABLE_DECIMAL_DATA_TYPE_KEY

public static final String ENABLE_DECIMAL_DATA_TYPE_KEY

See Also:

Constant Field Values

ENABLE_DECIMAL_DATA_TYPE

public static final TypeValidators.BooleanValidator ENABLE_DECIMAL_DATA_TYPE

HEP_OPT

public static final OptionValidator HEP_OPT

HEP_PARTITION_PRUNING

public static final OptionValidator HEP_PARTITION_PRUNING

ROWKEYJOIN_CONVERSION

public static final OptionValidator ROWKEYJOIN_CONVERSION

ROWKEYJOIN_CONVERSION_SELECTIVITY_THRESHOLD

public static final TypeValidators.RangeDoubleValidator ROWKEYJOIN_CONVERSION_SELECTIVITY_THRESHOLD

ROWKEYJOIN_CONVERSION_USING_HASHJOIN

public static final OptionValidator ROWKEYJOIN_CONVERSION_USING_HASHJOIN

PLANNER_MEMORY_LIMIT

public static final OptionValidator PLANNER_MEMORY_LIMIT

UNIONALL_DISTRIBUTE_KEY

public static final String UNIONALL_DISTRIBUTE_KEY

See Also:

Constant Field Values

UNIONALL_DISTRIBUTE

public static final TypeValidators.BooleanValidator UNIONALL_DISTRIBUTE

USE_SIMPLE_OPTIMIZER_KEY

public static final String USE_SIMPLE_OPTIMIZER_KEY

See Also:

Constant Field Values

USE_SIMPLE_OPTIMIZER

public static final TypeValidators.BooleanValidator USE_SIMPLE_OPTIMIZER

INDEX_PLANNING

public static final TypeValidators.BooleanValidator INDEX_PLANNING

ENABLE_STATS

public static final TypeValidators.BooleanValidator ENABLE_STATS

DISABLE_FULL_TABLE_SCAN

public static final TypeValidators.BooleanValidator DISABLE_FULL_TABLE_SCAN

INDEX_MAX_CHOSEN_INDEXES_PER_TABLE

public static final TypeValidators.RangeLongValidator INDEX_MAX_CHOSEN_INDEXES_PER_TABLE

INDEX_FORCE_SORT_NONCOVERING

public static final TypeValidators.BooleanValidator INDEX_FORCE_SORT_NONCOVERING

INDEX_USE_HASHJOIN_NONCOVERING

public static final TypeValidators.BooleanValidator INDEX_USE_HASHJOIN_NONCOVERING

INDEX_COVERING_SELECTIVITY_THRESHOLD

public static final TypeValidators.RangeDoubleValidator INDEX_COVERING_SELECTIVITY_THRESHOLD

INDEX_NONCOVERING_SELECTIVITY_THRESHOLD

public static final TypeValidators.RangeDoubleValidator INDEX_NONCOVERING_SELECTIVITY_THRESHOLD

INDEX_ROWKEYJOIN_COST_FACTOR

public static final TypeValidators.RangeDoubleValidator INDEX_ROWKEYJOIN_COST_FACTOR

INDEX_PREFER_INTERSECT_PLANS

public static final TypeValidators.BooleanValidator INDEX_PREFER_INTERSECT_PLANS

INDEX_MAX_INDEXES_TO_INTERSECT

public static final TypeValidators.RangeLongValidator INDEX_MAX_INDEXES_TO_INTERSECT

INDEX_STATS_ROWCOUNT_SCALING_FACTOR

public static final TypeValidators.RangeDoubleValidator INDEX_STATS_ROWCOUNT_SCALING_FACTOR

IDENTIFIER_MAX_LENGTH

public static final OptionValidator IDENTIFIER_MAX_LENGTH

FILTER_MIN_SELECTIVITY_ESTIMATE_FACTOR

public static final TypeValidators.DoubleValidator FILTER_MIN_SELECTIVITY_ESTIMATE_FACTOR

FILTER_MAX_SELECTIVITY_ESTIMATE_FACTOR

public static final TypeValidators.DoubleValidator FILTER_MAX_SELECTIVITY_ESTIMATE_FACTOR

TYPE_INFERENCE_KEY

public static final String TYPE_INFERENCE_KEY

See Also:

Constant Field Values

TYPE_INFERENCE

public static final TypeValidators.BooleanValidator TYPE_INFERENCE

IN_SUBQUERY_THRESHOLD

public static final TypeValidators.LongValidator IN_SUBQUERY_THRESHOLD

PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_KEY

public static final String PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_KEY

See Also:

Constant Field Values

PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING

public static final TypeValidators.BooleanValidator PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING

PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD_KEY

public static final String PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD_KEY

See Also:

Constant Field Values

PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD

public static final TypeValidators.LongValidator PARQUET_ROWGROUP_FILTER_PUSHDOWN_PLANNING_THRESHOLD

QUOTING_IDENTIFIERS_KEY

public static final String QUOTING_IDENTIFIERS_KEY

See Also:

Constant Field Values

QUOTING_IDENTIFIERS

public static final TypeValidators.EnumeratedStringValidator QUOTING_IDENTIFIERS

ENABLE_UNNEST_LATERAL_KEY

public static final String ENABLE_UNNEST_LATERAL_KEY

See Also:

Constant Field Values

ENABLE_UNNEST_LATERAL

public static final TypeValidators.BooleanValidator ENABLE_UNNEST_LATERAL

JOIN_OPTIMIZATION

public static final TypeValidators.BooleanValidator JOIN_OPTIMIZATION

FORCE_2PHASE_AGGR_KEY

public static final String FORCE_2PHASE_AGGR_KEY

See Also:

Constant Field Values

FORCE_2PHASE_AGGR

public static final TypeValidators.BooleanValidator FORCE_2PHASE_AGGR

STATISTICS_USE

public static final TypeValidators.BooleanValidator STATISTICS_USE

STATISTICS_MULTICOL_NDV_ADJUST_FACTOR

public static final TypeValidators.RangeDoubleValidator STATISTICS_MULTICOL_NDV_ADJUST_FACTOR

options

public OptionManager options

functionImplementationRegistry

public FunctionImplementationRegistry functionImplementationRegistry

Constructor Detail

PlannerSettings

public PlannerSettings(OptionManager options,
                       FunctionImplementationRegistry functionImplementationRegistry)

Method Detail

getOptions

public OptionManager 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

public String getFsPartitionColumnLabel()

getIdentifierMaxLength

public long getIdentifierMaxLength()

getPlanningMemoryLimit

public long getPlanningMemoryLimit()

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

public <T> T unwrap(Class<T> clazz)

Specified by:

unwrap in interface org.apache.calcite.schema.Wrapper