Uses of Interface
org.apache.drill.exec.server.options.OptionManager
Package
Description
Kafka storage plugin.
-
Uses of OptionManager in org.apache.drill.exec.expr.fn
ModifierConstructorDescriptionFunctionImplementationRegistry
(DrillConfig config, ScanResult classpathScan, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.metastore
-
Uses of OptionManager in org.apache.drill.exec.ops
Modifier 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
Modifier and TypeMethodDescriptionBasicOptimizer.BasicOptimizationContext.getOptions()
Optimizer.OptimizationContext.getOptions()
-
Uses of OptionManager in org.apache.drill.exec.physical.base
Modifier 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
Modifier and TypeMethodDescriptionvoid
HLLMergedStatistic.configure
(OptionManager optionsManager) void
TDigestMergedStatistic.configure
(OptionManager optionsManager) ModifierConstructorDescriptionNDVConfiguration
(OptionManager optionsManager, List<MergedStatistic> statistics) -
Uses of OptionManager in org.apache.drill.exec.physical.impl.xsort
-
Uses of OptionManager in org.apache.drill.exec.planner.physical
Modifier 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.ModifierConstructorDescriptionPlannerSettings
(OptionManager options, FunctionImplementationRegistry functionImplementationRegistry, String queryUser, AliasRegistryProvider aliasRegistryProvider) -
Uses of OptionManager in org.apache.drill.exec.planner.physical.visitor
Modifier and TypeMethodDescriptionstatic boolean
MemoryEstimationVisitor.enoughMemory
(Prel prel, OptionManager options, int numDrillbits) static Prel
InsertLocalExchangeVisitor.insertLocalExchanges
(Prel prel, OptionManager options) -
Uses of OptionManager in org.apache.drill.exec.planner.sql
ModifierConstructorDescriptionDrillOperatorTable
(FunctionImplementationRegistry registry, OptionManager systemOptionManager) -
Uses of OptionManager in org.apache.drill.exec.rpc.user
Modifier and TypeMethodDescriptionUserSession.Builder.withOptionManager
(OptionManager systemOptions) -
Uses of OptionManager in org.apache.drill.exec.server.options
Modifier 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
.Modifier and TypeMethodDescriptionQueryOptionManager.getOptionManager
(OptionValue.OptionScope scope) ModifierConstructorDescriptionFallbackOptionManager
(OptionManager fallback) FragmentOptionManager
(OptionManager systemOptions, OptionList options) QueryOptionManager
(OptionManager sessionOptions) SessionOptionManager
(OptionManager systemOptions, UserSession session) -
Uses of OptionManager in org.apache.drill.exec.store
Modifier 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.ModifierConstructorDescriptionColumnExplorer
(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
Modifier 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
Modifier and TypeMethodDescriptionDeltaScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.dfs
Modifier 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
Modifier and TypeMethodDescriptionTextFormatPlugin.getGroupScan
(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProviderManager) -
Uses of OptionManager in org.apache.drill.exec.store.hive
Modifier and TypeMethodDescriptionHiveDrillNativeParquetScanBatchCreator.getDrillFileSystemCreator
(OperatorContext operatorContext, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.http.udfs
Modifier 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
Modifier and TypeMethodDescription<S> PojoRecordReader<S>
InfoSchemaTableType.getRecordReader
(org.apache.calcite.schema.SchemaPlus rootSchema, InfoSchemaFilter filter, OptionManager optionManager, MetastoreRegistry metastoreRegistry) ModifierConstructorDescriptionBasicRecordCollector
(FilterEvaluator filterEvaluator, OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.kafka
ModifierConstructorDescriptionKafkaRecordReader
(KafkaPartitionScanSpec subScanSpec, OptionManager options, KafkaStoragePlugin plugin, int maxRecords) ReadOptions
(OptionManager optionManager) -
Uses of OptionManager in org.apache.drill.exec.store.parquet
Modifier 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
Modifier 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) ModifierConstructorDescriptionParquetSchema
(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
ModifierConstructorDescriptionRecordBatchSizerManager
(OptionManager options, ParquetSchema schema, long totalRecordsToRead, RecordBatchStats.RecordBatchStatsContext batchStatsContext) Constructor. -
Uses of OptionManager in org.apache.drill.exec.store.parquet2
ModifierConstructorDescriptionprotected
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
ModifierConstructorDescriptionExecutionControls
(OptionManager options) ExecutionControls
(OptionManager options, CoordinationProtos.DrillbitEndpoint endpoint) -
Uses of OptionManager in org.apache.drill.exec.util
-
Uses of OptionManager in org.apache.drill.exec.work.user