Uses of Package
org.apache.drill.exec.store
Package
Description
Handles optional file metadata columns: implicit columns and
partition columns.
Drill storage plugin.
Kafka storage plugin.
Defines a mock data source which generates dummy test data for use
in testing.
MongoDB storage plugin.
-
ClassDescriptionContains information needed by
AbstractSchema
implementations.Exposes partition information for a particular schema. -
ClassDescriptionExposes partition information to UDFs to allow queries to limit reading partitions dynamically.Contains information needed by
AbstractSchema
implementations.Interface to implement to provide required info forSchemaConfig
-
ClassDescriptionAbstract class for StorePlugin implementations.Contains list of parameters that will be used to store path / files on file system.
-
-
-
ClassDescriptionColumns that give information from where file data comes from.Columns that give internal information about file or its parts.
-
ClassDescriptionInterface for all implementations of the storage plugins.
-
ClassDescriptionInterface for all implementations of the storage plugins.Contains list of parameters that will be used to store path / files on file system.
-
-
-
ClassDescriptionFor new implementations please use new
ManagedReader
Interface for all implementations of the storage plugins. -
-
ClassDescriptionContains list of parameters that will be used to store path / files on file system.
-
-
ClassDescriptionStorage plugins implements this interface to register the schemas they provide.
-
-
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.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.Exposes partition information to UDFs to allow queries to limit reading partitions dynamically.Generalized interface for bootstraping or upgrading the plugin persistent store.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.For new implementations please use newManagedReader
RecordWriter interface.Contains information needed byAbstractSchema
implementations.Interface to implement to provide required info forSchemaConfig
Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Interface for collecting and obtaining statistics.Interface for all implementations of the storage plugins.Indicates an error when decoding a plugin from JSON.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.Contains list of parameters that will be used to store path / files on file system.Allows parallel executions of tasks in a simplified way. -
-
ClassDescriptionAbstract class for StorePlugin implementations.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Interface for all implementations of the storage plugins. -
-
-
-
-
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Abstract class for StorePlugin implementations.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Interface for all implementations of the storage plugins.Contains list of parameters that will be used to store path / files on file system. -
ClassDescriptionFor new implementations please use new
ManagedReader
RecordWriter interface.Contains list of parameters that will be used to store path / files on file system. -
-
ClassDescriptionAbstract class for StorePlugin implementations.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
-
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema. -
ClassDescriptionAbstract class for StorePlugin implementations.For new implementations please use new
ManagedReader
Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema. -
ClassDescriptionAbstract 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.For new implementations please use newManagedReader
RecordWriter interface.Interface for collecting and obtaining statistics.Contains list of parameters that will be used to store path / files on file system. -
ClassDescriptionThis class represents an implicit column in a dataset.
-
-
ClassDescriptionRecordWriter interface.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. -
ClassDescriptionAbstract class for StorePlugin implementations.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract class for StorePlugin implementations.RecordWriter interface.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Contains list of parameters that will be used to store path / files on file system. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Abstract class for StorePlugin implementations.For new implementations please use newManagedReader
Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract class for StorePlugin implementations.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
-
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Abstract class for StorePlugin implementations.This class represents an implicit column in a dataset.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Interface for all implementations of the storage plugins. -
-
-
-
ClassDescriptionAbstract class for StorePlugin implementations.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins.Indicates system plugins which will be dynamically initialized during storage plugin registry init stage. -
ClassDescriptionAbstract class for StorePlugin implementations.RecordWriter interface.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Interface for all implementations of the storage plugins.Contains list of parameters that will be used to store path / files on file system. -
ClassDescriptionContains information needed by
AbstractSchema
implementations.Exposes partition information for a particular schema. -
ClassDescriptionAbstract class for StorePlugin implementations.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Abstract class for StorePlugin implementations.For new implementations please use newManagedReader
RecordWriter interface.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract class for StorePlugin implementations.For new implementations please use new
ManagedReader
Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract class for StorePlugin implementations.For new implementations please use new
ManagedReader
Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
-
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema. -
ClassDescriptionAbstract class for StorePlugin implementations.For new implementations please use new
ManagedReader
Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide. -
ClassDescriptionAbstract 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.RecordWriter interface.Contains list of parameters that will be used to store path / files on file system. -
-
-
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Abstract class for StorePlugin implementations.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins. -
-
-
ClassDescriptionDefines names and data types of columns in a static drill table.For new implementations please use new
ManagedReader
-
ClassDescriptionAbstract implementation of
SchemaFactory
, ensures that given schema name is always converted is lower case.Abstract class for StorePlugin implementations.RecordWriter interface.Contains information needed byAbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Exposes partition information for a particular schema.Interface for all implementations of the storage plugins.Contains list of parameters that will be used to store path / files on file system. -
ClassDescriptionAbstract class for StorePlugin implementations.Defines names and data types of columns in a static drill table.Contains information needed by
AbstractSchema
implementations.Storage plugins implements this interface to register the schemas they provide.Interface for all implementations of the storage plugins.Indicates system plugins which will be dynamically initialized during storage plugin registry init stage. -
ClassDescriptionThis class represents an implicit column in a dataset.