Interface | Description |
---|---|
ColumnExplorer.ImplicitFileColumn | |
ConnectorLocator |
Locates storage plugins.
|
PartitionExplorer |
Exposes partition information to UDFs to allow queries to limit reading
partitions dynamically.
|
PluginBootstrapLoader |
Generalized interface for bootstraping or upgrading the plugin persistent
store.
|
PluginRegistryContext |
Provides a loose coupling of the plugin registry to the resources it needs
from elsewhere.
|
PluginRulesProvider |
Provides rules required for adding support of specific operator pushdown for storage plugin.
|
RecordReader | |
RecordWriter |
RecordWriter interface.
|
SchemaConfig.SchemaConfigInfoProvider |
Interface to implement to provide required info for
SchemaConfig |
SchemaFactory |
Storage plugins implements this interface to register the schemas they provide.
|
SchemaPartitionExplorer |
Exposes partition information for a particular schema.
|
StatisticsRecordCollector |
Interface for collecting and obtaining statistics.
|
StatisticsRecordWriter | |
StoragePlugin |
Interface for all implementations of the storage plugins.
|
StoragePluginRegistry | |
StoragePluginStore |
Interface to the storage mechanism used to store storage plugin
configurations, typically in JSON format.
|
Class | Description |
---|---|
AbstractRecordReader | |
AbstractRecordWriter | |
AbstractSchema | |
AbstractSchemaFactory |
Abstract implementation of
SchemaFactory , ensures that given schema
name is always converted is lower case. |
AbstractStoragePlugin |
Abstract class for StorePlugin implementations.
|
ClassicConnectorLocator |
Plugin locator for the "classic" class-path method of locating connectors.
|
ClassPathFileSystem | |
ColumnExplorer | |
CommonParquetRecordReader | |
ConnectorHandle |
Defines a storage connector: a storage plugin config along with the
locator which can create a plugin instance given an instance of the
config.
|
DrillbitPluginRegistryContext |
Implementation of the storage registry context which obtains the
needed resources from the
DrillbitContext . |
DrillSchemaFactory | |
EventBasedRecordWriter |
Reads records from the RecordValueAccessor and writes into RecordWriter.
|
EventBasedRecordWriter.FieldConverter | |
ImplicitColumnUtils | |
ImplicitColumnUtils.ImplicitColumn | |
ImplicitColumnUtils.ImplicitColumns |
This class represents an implicit column in a dataset.
|
JSONBaseStatisticsRecordWriter |
Abstract implementation of StatisticsRecordWriter interface which exposes interface:
#writeHeader(List)
#addField(int,String)
to output the data in string format instead of implementing addField for each type holder. |
JSONOutputRecordWriter |
Abstract implementation of RecordWriter interface which exposes interface:
#writeHeader(List)
#addField(int,String)
to output the data in string format instead of implementing addField for each type holder. |
LocalSyncableFileSystem |
A syncable local extension of the Hadoop FileSystem
|
ParquetOutputRecordWriter |
Abstract implementation of RecordWriter interface which exposes interface:
#writeHeader(List)
#addField(int,String)
to output the data in string format instead of implementing addField for each type holder. |
PartitionExplorerImpl | |
PluginBootstrapLoaderImpl |
Loads the set of bootstrap plugin configurations for new systems.
|
PluginHandle |
Represents a storage plugin, defined by a (name, config) pair.
|
PluginRulesProviderImpl | |
RecordDataType |
Defines names and data types of columns in a static drill table.
|
ResourceInputStream | |
SchemaConfig |
Contains information needed by
AbstractSchema implementations. |
SchemaConfig.Builder | |
SchemaTreeProvider |
Creates new schema trees.
|
StatisticsRecordWriterImpl |
Reads records from the RecordValueAccessor and writes into StatisticsRecordCollector.
|
StoragePluginOptimizerRule | |
StoragePluginRegistryImpl |
Plugin registry.
|
StoragePluginRulesSupplier |
Helper class that can be used to obtain rules required for pushing down operators
that specific plugin supports configured using
StoragePluginRulesSupplier.StoragePluginRulesSupplierBuilder . |
StoragePluginRulesSupplier.StoragePluginRulesSupplierBuilder | |
StoragePluginStoreImpl |
Concrete storage plugin (configuration) store based on the
PersistentStore abstraction. |
StorageStrategy |
Contains list of parameters that will be used to store path / files on file system.
|
StringOutputRecordWriter |
Abstract implementation of RecordWriter interface which exposes interface:
StringOutputRecordWriter.startNewSchema(BatchSchema)
StringOutputRecordWriter.addField(int,String)
to output the data in string format instead of implementing addField for each type holder. |
SubSchemaWrapper | |
SubsetRemover |
Removes
RelSubset nodes from the plan. |
SystemPluginLocator |
Locates system storage plugins.
|
TimedCallable<V> |
Allows parallel executions of tasks in a simplified way.
|
Enum | Description |
---|---|
ColumnExplorer.ImplicitFileColumns |
Columns that give information from where file data comes from.
|
ColumnExplorer.ImplicitInternalFileColumns |
Columns that give internal information about file or its parts.
|
CommonParquetRecordReader.Metric | |
StoragePluginRegistry.PluginFilter |
Exception | Description |
---|---|
PartitionNotFoundException | |
StoragePluginRegistry.PluginEncodingException |
Indicates an error when decoding a plugin from JSON.
|
StoragePluginRegistry.PluginException | |
StoragePluginRegistry.PluginNotFoundException |
Indicates the requested plugin was not found.
|
Annotation Type | Description |
---|---|
PrivatePlugin |
Indicates private plugins which will be excluded from automatic plugin
discovery.
|
SystemPlugin |
Indicates system plugins which will be dynamically initialized during storage
plugin registry init stage.
|
Copyright © 1970 The Apache Software Foundation. All rights reserved.