Package org.apache.drill.exec.store
package org.apache.drill.exec.store
-
ClassDescriptionAbstract implementation of
SchemaFactory, ensures that given schema name is always converted is lower case.Abstract class for StorePlugin implementations.Plugin locator for the "classic" class-path method of locating connectors.Columns that give information from where file data comes from.Columns that give internal information about file or its parts.Defines a storage connector: a storage plugin config along with the locator which can create a plugin instance given an instance of the config.Locates storage plugins.Implementation of the storage registry context which obtains the needed resources from theDrillbitContext.Reads records from the RecordValueAccessor and writes into RecordWriter.This class represents an implicit column in a dataset.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.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.A syncable local extension of the Hadoop FileSystemAbstract 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.Exposes partition information to UDFs to allow queries to limit reading partitions dynamically.Generalized interface for bootstraping or upgrading the plugin persistent store.Loads the set of bootstrap plugin configurations for new systems.Represents a storage plugin, defined by a (name, config) pair.Provides a loose coupling of the plugin registry to the resources it needs from elsewhere.Provides rules required for adding support of specific operator pushdown for storage plugin.Indicates private plugins which will be excluded from automatic plugin discovery.Defines names and data types of columns in a static drill table.For new implementations please use newManagedReaderRecordWriter interface.Contains information needed byAbstractSchemaimplementations.Interface to implement to provide required info forSchemaConfigStorage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Creates new schema trees.Interface for collecting and obtaining statistics.Reads records from the RecordValueAccessor and writes into StatisticsRecordCollector.Interface for all implementations of the storage plugins.Indicates an error when decoding a plugin from JSON.Indicates the requested plugin was not found.Plugin registry.Helper class that can be used to obtain rules required for pushing down operators that specific plugin supports configured usingStoragePluginRulesSupplier.StoragePluginRulesSupplierBuilder.Interface to the storage mechanism used to store storage plugin configurations, typically in JSON format.Concrete storage plugin (configuration) store based on thePersistentStoreabstraction.Contains list of parameters that will be used to store path / files on file system.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.RemovesRelSubsetnodes from the plan.Indicates system plugins which will be dynamically initialized during storage plugin registry init stage.Locates system storage plugins.Allows parallel executions of tasks in a simplified way.