Uses of Interface
org.apache.drill.exec.server.options.OptionManager
Packages that use OptionManager
Package
Description
Kafka storage plugin.
-
Uses of OptionManager in org.apache.drill.exec.expr.fn
Constructors in org.apache.drill.exec.expr.fn with parameters of type OptionManagerModifierConstructorDescriptionFunctionImplementationRegistry
(DrillConfig config, ScanResult classpathScan, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.metastore
Constructors in org.apache.drill.exec.metastore with parameters of type OptionManager -
Uses of OptionManager in org.apache.drill.exec.ops
Methods in org.apache.drill.exec.ops that return OptionManagerModifier and TypeMethodDescriptionFragmentContext.getOptions()
Returns a read-only version of the session options.FragmentContextImpl.getOptions()
FragmentContextInterface.getOptions()
Returns the session options. -
Uses of OptionManager in org.apache.drill.exec.opt
Methods in org.apache.drill.exec.opt that return OptionManagerModifier and TypeMethodDescriptionBasicOptimizer.BasicOptimizationContext.getOptions()
Optimizer.OptimizationContext.getOptions()
-
Uses of OptionManager in org.apache.drill.exec.physical.base
Methods in org.apache.drill.exec.physical.base with parameters of type OptionManagerModifier and TypeMethodDescriptionAbstractGroupScan.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) AbstractGroupScanWithMetadata.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) Applies specified filterfilterExpr
to current group scan and produces filtering at: table level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null segment level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if segment metadata was pruned, prunes underlying metadata partition level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if partition metadata was pruned, prunes underlying metadata file level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns nullGroupScan.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterAndGetMetadata
(Set<SchemaPath> schemaPathsInExpr, Iterable<T> metadataList, FilterPredicate<?> filterPredicate, OptionManager optionManager) Produces filtering of specified metadata using specified filter expression and returns filtered metadata.protected void
AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterFileMetadata
(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at file level.protected void
AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterPartitionMetadata
(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at partition level.protected void
AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.filterSegmentMetadata
(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at segment level.protected B
AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.getFiltered
(OptionManager optionManager, FilterPredicate<?> filterPredicate) Produces filtering of metadata and returnsAbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer
to construct resulting group scan.AbstractGroupScanWithMetadata.getFilterPredicate
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, OptionManager optionManager, boolean omitUnsupportedExprs) static FilterPredicate<?>
AbstractGroupScanWithMetadata.getFilterPredicate
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, OptionManager optionManager, boolean omitUnsupportedExprs, boolean supportsFileImplicitColumns, TupleMetadata schema) Returns parquet filter predicate built from specifiedfilterExpr
.protected <T extends Metadata>
Map<SchemaPath,ColumnStatistics<?>> AbstractGroupScanWithMetadata.GroupScanWithMetadataFilterer.getImplicitColumnStatistics
(OptionManager optionManager, T metadata, Map<SchemaPath, ColumnStatistics<?>> columnsStatistics) static boolean
AbstractGroupScanWithMetadata.isImplicitOrPartCol
(SchemaPath schemaPath, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.physical.impl.statistics
Methods in org.apache.drill.exec.physical.impl.statistics with parameters of type OptionManagerModifier and TypeMethodDescriptionvoid
HLLMergedStatistic.configure
(OptionManager optionsManager) void
TDigestMergedStatistic.configure
(OptionManager optionsManager) Constructors in org.apache.drill.exec.physical.impl.statistics with parameters of type OptionManagerModifierConstructorDescriptionNDVConfiguration
(OptionManager optionsManager, List<MergedStatistic> statistics) -
Uses of OptionManager in org.apache.drill.exec.physical.impl.xsort
Constructors in org.apache.drill.exec.physical.impl.xsort with parameters of type OptionManager -
Uses of OptionManager in org.apache.drill.exec.planner.physical
Fields in org.apache.drill.exec.planner.physical declared as OptionManagerMethods in org.apache.drill.exec.planner.physical that return OptionManagerMethods in org.apache.drill.exec.planner.physical with parameters of type OptionManagerModifier and TypeMethodDescriptionExchangePrel.constructMuxPrel
(Prel child, OptionManager options) The derived classes can override this method to create relevant mux exchanges.HashToRandomExchangePrel.constructMuxPrel
(Prel child, OptionManager options) This method creates a new UnorderedMux and Demux exchanges if mux operators are enabled.SingleMergeExchangePrel.constructMuxPrel
(Prel child, OptionManager options) This method creates a new OrderedMux exchange if mux operators are enabled.Constructors in org.apache.drill.exec.planner.physical with parameters of type OptionManagerModifierConstructorDescriptionPlannerSettings
(OptionManager options, FunctionImplementationRegistry functionImplementationRegistry, String queryUser, AliasRegistryProvider aliasRegistryProvider) -
Uses of OptionManager in org.apache.drill.exec.planner.physical.visitor
Methods in org.apache.drill.exec.planner.physical.visitor with parameters of type OptionManagerModifier and TypeMethodDescriptionstatic boolean
MemoryEstimationVisitor.enoughMemory
(Prel prel, OptionManager options, int numDrillbits) static Prel
InsertLocalExchangeVisitor.insertLocalExchanges
(Prel prel, OptionManager options) Constructors in org.apache.drill.exec.planner.physical.visitor with parameters of type OptionManager -
Uses of OptionManager in org.apache.drill.exec.planner.sql
Constructors in org.apache.drill.exec.planner.sql with parameters of type OptionManagerModifierConstructorDescriptionDrillOperatorTable
(FunctionImplementationRegistry registry, OptionManager systemOptionManager) -
Uses of OptionManager in org.apache.drill.exec.rpc.user
Methods in org.apache.drill.exec.rpc.user with parameters of type OptionManagerModifier and TypeMethodDescriptionUserSession.Builder.withOptionManager
(OptionManager systemOptions) -
Uses of OptionManager in org.apache.drill.exec.server.options
Classes in org.apache.drill.exec.server.options that implement OptionManagerModifier and TypeClassDescriptionclass
ThisOptionManager
implements some the basic methods and should be extended by concrete implementations.class
AnOptionManager
which allows for falling back onto anotherOptionManager
when retrieving options.class
OptionManager
that holds options withinFragmentContextImpl
.class
This is anOptionManager
that holds options in memory rather than in a persistent store.class
OptionManager
that holds options withinQueryContext
.class
OptionManager
that holds options withinUserSession
context.class
OptionManager
that holds options withinDrillbitContext
.Fields in org.apache.drill.exec.server.options declared as OptionManagerMethods in org.apache.drill.exec.server.options that return OptionManagerModifier and TypeMethodDescriptionQueryOptionManager.getOptionManager
(OptionValue.OptionScope scope) Constructors in org.apache.drill.exec.server.options with parameters of type OptionManagerModifierConstructorDescriptionFallbackOptionManager
(OptionManager fallback) FragmentOptionManager
(OptionManager systemOptions, OptionList options) QueryOptionManager
(OptionManager sessionOptions) SessionOptionManager
(OptionManager systemOptions, UserSession session) -
Uses of OptionManager in org.apache.drill.exec.store
Methods in org.apache.drill.exec.store with parameters of type OptionManagerModifier and TypeMethodDescriptionorg.apache.calcite.schema.SchemaPlus
SchemaTreeProvider.createRootSchema
(OptionManager options) Return root schema for process user.ColumnExplorer.initImplicitFileColumns
(OptionManager optionManager) Creates case insensitive map with implicit file columns as keys and appropriate ImplicitFileColumns enum as valuesColumnExplorer.initImplicitInternalFileColumns
(OptionManager optionManager) Creates case insensitive map with implicit internal file columns as keys and appropriate ImplicitFileColumns enum as valuesstatic boolean
ColumnExplorer.isPartitionColumn
(OptionManager optionManager, SchemaPath column) Checks if given column is partition or not.Constructors in org.apache.drill.exec.store with parameters of type OptionManagerModifierConstructorDescriptionColumnExplorer
(OptionManager optionManager) Constructor for using the column explorer to probe existing columns in theProjectRecordBatch
.ColumnExplorer
(OptionManager optionManager, List<SchemaPath> columns) Helper class that encapsulates logic for sorting out columns between actual table columns, partition columns and implicit file columns. -
Uses of OptionManager in org.apache.drill.exec.store.delta.format
Methods in org.apache.drill.exec.store.delta.format with parameters of type OptionManagerModifier and TypeMethodDescriptionDeltaFormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options) DeltaFormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProviderManager) -
Uses of OptionManager in org.apache.drill.exec.store.delta.read
Methods in org.apache.drill.exec.store.delta.read with parameters of type OptionManagerModifier and TypeMethodDescriptionDeltaScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.dfs
Methods in org.apache.drill.exec.store.dfs with parameters of type OptionManagerModifier and TypeMethodDescriptiondefault AbstractGroupScan
FormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options) default AbstractGroupScan
FormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProvider) -
Uses of OptionManager in org.apache.drill.exec.store.easy.text
Methods in org.apache.drill.exec.store.easy.text with parameters of type OptionManagerModifier and TypeMethodDescriptionTextFormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProviderManager) -
Uses of OptionManager in org.apache.drill.exec.store.hive
Methods in org.apache.drill.exec.store.hive with parameters of type OptionManagerModifier and TypeMethodDescriptionHiveDrillNativeParquetScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.http.udfs
Methods in org.apache.drill.exec.store.http.udfs with parameters of type OptionManagerModifier and TypeMethodDescriptionstatic JsonLoaderImpl
HttpUdfUtils.createJsonLoader
(ResultSetLoader rsLoader, OptionManager options, ClosingStreamIterator stream) static JsonLoaderImpl
HttpUdfUtils.createJsonLoader
(HttpApiConfig endpointConfig, ResultSetLoader rsLoader, OptionManager options, ClosingStreamIterator stream) -
Uses of OptionManager in org.apache.drill.exec.store.ischema
Methods in org.apache.drill.exec.store.ischema with parameters of type OptionManagerModifier and TypeMethodDescription<S> PojoRecordReader<S>
InfoSchemaTableType.getRecordReader
(org.apache.calcite.schema.SchemaPlus rootSchema, InfoSchemaFilter filter, OptionManager optionManager, MetastoreRegistry metastoreRegistry) Constructors in org.apache.drill.exec.store.ischema with parameters of type OptionManagerModifierConstructorDescriptionBasicRecordCollector
(FilterEvaluator filterEvaluator, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.kafka
Constructors in org.apache.drill.exec.store.kafka with parameters of type OptionManagerModifierConstructorDescriptionKafkaRecordReader
(KafkaPartitionScanSpec subScanSpec, OptionManager options, KafkaStoragePlugin plugin, int maxRecords) ReadOptions
(OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.parquet
Methods in org.apache.drill.exec.store.parquet with parameters of type OptionManagerModifier and TypeMethodDescriptionstatic Map<SchemaPath,
ColumnStatistics<?>> ParquetTableMetadataUtils.addImplicitColumnsStatistics
(Map<SchemaPath, ColumnStatistics<?>> columnsStatistics, List<SchemaPath> columns, List<String> partitionValues, OptionManager optionManager, org.apache.hadoop.fs.Path location, boolean supportsFileImplicitColumns) Creates new map based on specifiedcolumnStatistics
with added statistics for implicit and partition (dir) columns.AbstractParquetGroupScan.applyFilter
(LogicalExpression filterExpr, UdfUtilities udfUtilities, FunctionImplementationRegistry functionImplementationRegistry, OptionManager optionManager) Applies specified filterfilterExpr
to current group scan and produces filtering at: table level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null segment level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if segment metadata was pruned, prunes underlying metadata partition level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns null if partition metadata was pruned, prunes underlying metadata file level: if filter matches all the the data or prunes all the data, sets corresponding value toAbstractGroupScanWithMetadata.isMatchAllMetadata()
and returns nullstatic void
ParquetReaderUtility.checkDecimalTypeEnabled
(OptionManager options) static RowsMatch
FilterEvaluatorUtils.evalFilter
(LogicalExpression expr, MetadataBase.ParquetTableMetadataBase footer, int rowGroupIndex, OptionManager options, FragmentContext fragmentContext) protected void
AbstractParquetGroupScan.RowGroupScanFilterer.filterFileMetadata
(OptionManager optionManager, FilterPredicate<?> filterPredicate, Set<SchemaPath> schemaPathsInExpr) Produces filtering of metadata at file level.protected void
AbstractParquetGroupScan.RowGroupScanFilterer.filterRowGroupMetadata
(OptionManager optionManager, FilterPredicate<?> filterPredicate) Produces filtering of metadata at row group level.protected abstract AbstractParquetScanBatchCreator.AbstractDrillFileSystemManager
AbstractParquetScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) ParquetScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) protected B
AbstractParquetGroupScan.RowGroupScanFilterer.getFiltered
(OptionManager optionManager, FilterPredicate<?> filterPredicate) ParquetFormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options) ParquetFormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProviderManager) ParquetReaderConfig.Builder.withOptions
(OptionManager options) -
Uses of OptionManager in org.apache.drill.exec.store.parquet.columnreaders
Methods in org.apache.drill.exec.store.parquet.columnreaders with parameters of type OptionManagerModifier and TypeMethodDescriptionvoid
ParquetColumnMetadata.resolveDrillType
(Map<String, org.apache.parquet.format.SchemaElement> schemaElements, OptionManager options) static TypeProtos.MajorType
ParquetToDrillTypeConverter.toMajorType
(org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName primitiveTypeName, int length, TypeProtos.DataMode mode, org.apache.parquet.format.SchemaElement schemaElement, OptionManager options) Constructors in org.apache.drill.exec.store.parquet.columnreaders with parameters of type OptionManagerModifierConstructorDescriptionParquetSchema
(OptionManager options, int rowGroupIndex, org.apache.parquet.hadoop.metadata.ParquetMetadata footer, Collection<SchemaPath> selectedCols) Build the Parquet schema. -
Uses of OptionManager in org.apache.drill.exec.store.parquet.columnreaders.batchsizing
Constructors in org.apache.drill.exec.store.parquet.columnreaders.batchsizing with parameters of type OptionManagerModifierConstructorDescriptionRecordBatchSizerManager
(OptionManager options, ParquetSchema schema, long totalRecordsToRead, RecordBatchStats.RecordBatchStatsContext batchStatsContext) Constructor. -
Uses of OptionManager in org.apache.drill.exec.store.parquet2
Constructors in org.apache.drill.exec.store.parquet2 with parameters of type OptionManagerModifierConstructorDescriptionprotected
DrillParquetGroupConverter
(OutputMutator mutator, BaseWriter baseWriter, OptionManager options, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates) Constructor is responsible for creation of converter without creation of child converters.DrillParquetGroupConverter
(OutputMutator mutator, BaseWriter baseWriter, org.apache.parquet.schema.GroupType schema, Collection<SchemaPath> columns, OptionManager options, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates, boolean skipRepeated, String parentName) The constructor is responsible for creation of converters tree and may invoke itself for creation of child converters when nested field is group type field too.DrillParquetRecordMaterializer
(OutputMutator mutator, org.apache.parquet.schema.MessageType schema, Collection<SchemaPath> columns, OptionManager options, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates) -
Uses of OptionManager in org.apache.drill.exec.testing
Constructors in org.apache.drill.exec.testing with parameters of type OptionManagerModifierConstructorDescriptionExecutionControls
(OptionManager options) ExecutionControls
(OptionManager options, CoordinationProtos.DrillbitEndpoint endpoint) -
Uses of OptionManager in org.apache.drill.exec.util
Constructors in org.apache.drill.exec.util with parameters of type OptionManager -
Uses of OptionManager in org.apache.drill.exec.work.user
Methods in org.apache.drill.exec.work.user that return OptionManager