Uses of Class
org.apache.drill.common.logical.StoragePluginConfig
Package
Description
Storage plugin interfaces and logical plan representation.
Drill storage plugin.
Kafka storage plugin.
Defines a mock data source which generates dummy test data for use
in testing.
MongoDB storage plugin.
-
Uses of StoragePluginConfig in org.apache.drill.common.logical
Modifier and TypeMethodDescriptionLogicalPlan.getStorageEngineConfig
(String name) StoragePluginConfig.updateCredentialProvider
(CredentialsProvider credentialsProvider) Modifier and TypeMethodDescriptionLogicalPlanBuilder.addStorageEngine
(String name, StoragePluginConfig config) ModifierConstructorDescriptionLogicalPlan
(PlanProperties head, Map<String, StoragePluginConfig> storageEngineMap, List<LogicalOperator> operators) -
Uses of StoragePluginConfig in org.apache.drill.exec.physical.base
Modifier and TypeMethodDescriptionabstract StoragePluginConfig
AbstractDbGroupScan.getStorageConfig()
-
Uses of StoragePluginConfig in org.apache.drill.exec.planner.index
Modifier and TypeMethodDescriptionstatic IndexDiscover
IndexDiscoverFactory.getIndexDiscover
(StoragePluginConfig config, GroupScan inScan, org.apache.calcite.rel.RelNode scanRel, Class<? extends IndexDiscover> targetIndexDiscoverClass) -
Uses of StoragePluginConfig in org.apache.drill.exec.planner.logical
Modifier and TypeMethodDescriptionReturn storage plugin config for certain plugin nameDrillTable.getStorageEngineConfig()
StoragePlugins.putIfAbsent
(String name, StoragePluginConfig config) Put one plugin into current storage plugins map, if it was absentModifier and TypeMethodDescriptionvoid
StoragePlugins.put
(String name, StoragePluginConfig config) Put one plugin into current storage plugins mapStoragePlugins.putIfAbsent
(String name, StoragePluginConfig config) Put one plugin into current storage plugins map, if it was absent -
Uses of StoragePluginConfig in org.apache.drill.exec.server.rest
-
Uses of StoragePluginConfig in org.apache.drill.exec.store
Modifier and TypeMethodDescriptionPluginHandle.config()
StoragePluginRegistry.copyConfig
(String name) Copy a stored config so that it can be modified.StoragePluginRegistry.copyConfig
(StoragePluginConfig config) Copy the given storage plugin config so it may be modified.StoragePluginRegistryImpl.copyConfig
(String name) StoragePluginRegistryImpl.copyConfig
(StoragePluginConfig orig) Return a config decoded from JSON.StoragePlugin.getConfig()
Method returns a Jackson serializable object that extends a StoragePluginConfig.StoragePluginRegistry.getDefinedConfig
(String name) Retrieve an available configuration.StoragePluginRegistryImpl.getDefinedConfig
(String name) StoragePluginRegistry.getStoredConfig
(String name) Return a plugin from persistent storage.StoragePluginRegistryImpl.getStoredConfig
(String name) Configs are obtained from the persistent store.Modifier and TypeMethodDescriptionClass<? extends StoragePluginConfig>
ConnectorHandle.configClass()
Set<Class<? extends StoragePluginConfig>>
ClassicConnectorLocator.configClasses()
Set<Class<? extends StoragePluginConfig>>
ConnectorLocator.configClasses()
Return the set of known storage plugin configuration classes for which the user can create configs.Set<Class<? extends StoragePluginConfig>>
SystemPluginLocator.configClasses()
static Map<Class<? extends StoragePluginConfig>,
Constructor<? extends StoragePlugin>> ClassicConnectorLocator.constuctorsFor
(Class<? extends StoragePlugin> plugin) StoragePluginRegistry.enabledConfigs()
Returns a copy of the set of enabled stored plugin configurations.StoragePluginRegistryImpl.enabledConfigs()
StoragePluginStore.getStore()
StoragePluginStoreImpl.getStore()
StoragePluginStore.load()
StoragePluginStoreImpl.load()
StoragePluginRegistry.storedConfigs()
Returns a set of all stored plugin configurations, directly from the persistent store.StoragePluginRegistry.storedConfigs
(StoragePluginRegistry.PluginFilter filter) Return a possibly-filtered set of plugins from the persistent store.StoragePluginRegistryImpl.storedConfigs()
StoragePluginRegistryImpl.storedConfigs
(StoragePluginRegistry.PluginFilter filter) Modifier and TypeMethodDescriptionStoragePluginRegistry.copyConfig
(StoragePluginConfig config) Copy the given storage plugin config so it may be modified.StoragePluginRegistryImpl.copyConfig
(StoragePluginConfig orig) protected static void
StoragePluginRegistryImpl.copyPluginStatus
(StoragePluginConfig oldPluginConfig, StoragePluginConfig newPluginConfig) Identifies the enabled status for new storage plugins config.ClassicConnectorLocator.create
(String name, StoragePluginConfig pluginConfig) Creates plugin instance with the givenname
and configurationpluginConfig
.ConnectorLocator.create
(String name, StoragePluginConfig pluginConfig) Create a connector instance given a named configuration.SystemPluginLocator.create
(String name, StoragePluginConfig pluginConfig) StoragePluginRegistry.encode
(StoragePluginConfig config) StoragePluginRegistryImpl.encode
(StoragePluginConfig config) StoragePluginRegistry.getFormatPlugin
(StoragePluginConfig storageConfig, FormatPluginConfig formatConfig) Deprecated.StoragePluginRegistryImpl.getFormatPlugin
(StoragePluginConfig storageConfig, FormatPluginConfig formatConfig) StoragePluginRegistry.getFormatPluginByConfig
(StoragePluginConfig storageConfig, FormatPluginConfig formatConfig) Get the Format plugin for the FileSystemPlugin associated with the provided storage config and format config.StoragePluginRegistryImpl.getFormatPluginByConfig
(StoragePluginConfig storageConfig, FormatPluginConfig formatConfig) StoragePluginRegistry.getPlugin
(StoragePluginConfig config) Deprecated.useStoragePluginRegistry.resolve(StoragePluginConfig, Class)
which provides type safety.StoragePluginRegistryImpl.getPlugin
(StoragePluginConfig config) StoragePluginRegistry.getPluginByConfig
(StoragePluginConfig config) Get a plugin by configuration.StoragePluginRegistryImpl.getPluginByConfig
(StoragePluginConfig config) ConnectorHandle.newInstance
(String name, StoragePluginConfig config) ConnectorHandle.pluginEntryFor
(String name, StoragePluginConfig config, org.apache.drill.exec.store.PluginHandle.PluginType type) void
StoragePluginRegistry.put
(String name, StoragePluginConfig config) Store a plugin by name and configuration.void
StoragePluginRegistryImpl.put
(String name, StoragePluginConfig config) void
StoragePluginStore.put
(String name, StoragePluginConfig config) void
StoragePluginStoreImpl.put
(String name, StoragePluginConfig config) <T extends StoragePlugin>
TStoragePluginRegistry.resolve
(StoragePluginConfig storageConfig, Class<T> desired) <T extends StoragePlugin>
TStoragePluginRegistryImpl.resolve
(StoragePluginConfig storageConfig, Class<T> desired) <T extends FormatPlugin>
TStoragePluginRegistry.resolveFormat
(StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, Class<T> desired) Resolve a storage plugin given a storage plugin config.<T extends FormatPlugin>
TStoragePluginRegistryImpl.resolveFormat
(StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, Class<T> desired) void
StoragePluginRegistry.validatedPut
(String name, StoragePluginConfig config) LikeStoragePluginRegistry.put(String, StoragePluginConfig)
, but forces instantiation of the plugin to verify that the configuration is valid at this moment in time.void
StoragePluginRegistryImpl.validatedPut
(String name, StoragePluginConfig config) Modifier and TypeMethodDescriptionstatic ConnectorHandle
ConnectorHandle.configuredConnector
(ConnectorLocator locator, Class<? extends StoragePluginConfig> configClass) Construct a handle for a "normal" connector which takes a plugin config and constructs a plugin instance based on that config.Class<? extends StoragePlugin>
ClassicConnectorLocator.connectorClassFor
(Class<? extends StoragePluginConfig> configClass) Class<? extends StoragePlugin>
ConnectorLocator.connectorClassFor
(Class<? extends StoragePluginConfig> configClass) Given a configuration class, return the corresponding connector (plugin) class.Class<? extends StoragePlugin>
SystemPluginLocator.connectorClassFor
(Class<? extends StoragePluginConfig> configClass) ModifierConstructorDescriptionPluginHandle
(String name, StoragePluginConfig config, ConnectorHandle connector) PluginHandle
(String name, StoragePluginConfig config, ConnectorHandle connector, org.apache.drill.exec.store.PluginHandle.PluginType type) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.avro
ModifierConstructorDescriptionAvroFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, AvroFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.cassandra
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.delta
Modifier and TypeMethodDescriptionDeltaGroupScan.getStorageConfig()
DeltaRowGroupScan.getStorageConfig()
ModifierConstructorDescriptionDeltaGroupScan
(String userName, List<ReadEntryWithPath> entries, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, TupleMetadata schema, String path, ParquetReaderConfig readerConfig, LogicalExpression condition, Integer limit, Map<org.apache.hadoop.fs.Path, Map<String, String>> partitionHolder, StoragePluginRegistry pluginRegistry) DeltaRowGroupScan
(StoragePluginRegistry registry, String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatPluginConfig, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, Map<org.apache.hadoop.fs.Path, Map<String, String>> partitions, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.dfs
Modifier and TypeMethodDescriptionFileSystemPlugin.getConfig()
OAuthEnabledFileSystem.getPluginConfig()
FormatPlugin.getStorageConfig()
Modifier and TypeMethodDescriptionvoid
OAuthEnabledFileSystem.setPluginConfig
(StoragePluginConfig pluginConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.dfs.easy
Modifier and TypeMethodDescriptionEasyFormatPlugin.getStorageConfig()
EasyGroupScan.getStorageConfig()
EasySubScan.getStorageConfig()
EasyWriter.getStorageConfig()
ModifierConstructorDescriptionprotected
EasyFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, T formatConfig, boolean readable, boolean writable, boolean blockSplittable, boolean compressible, List<String> extensions, String defaultName) Legacy constructor.protected
EasyFormatPlugin
(String name, EasyFormatPlugin.EasyFormatConfig config, DrillbitContext context, StoragePluginConfig storageConfig, T formatConfig) Revised constructor in which settings are gathered into a configuration object.EasyGroupScan
(String userName, List<org.apache.hadoop.fs.Path> files, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, StoragePluginRegistry engineRegistry, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, TupleMetadata schema, int limit) EasySubScan
(String userName, List<CompleteFileWork.FileWorkImpl> files, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, StoragePluginRegistry engineRegistry, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, int partitionDepth, TupleMetadata schema, int limit) EasyWriter
(PhysicalOperator child, String location, List<String> partitionColumns, StorageStrategy storageStrategy, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.drill.plugin
ModifierConstructorDescriptionDrillSubScan
(String userName, StoragePluginConfig pluginConfig, String query) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.druid
ModifierConstructorDescriptionDruidSubScan
(StoragePluginRegistry registry, String userName, StoragePluginConfig config, LinkedList<DruidSubScan.DruidSubScanSpec> datasourceScanSpecList, List<SchemaPath> columns, int maxRecordsToRead) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.easy.json
ModifierConstructorDescriptionJSONFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig) JSONFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig config, JSONFormatConfig formatPluginConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.easy.sequencefile
ModifierConstructorDescriptionSequenceFileFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, SequenceFileFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.easy.text
ModifierConstructorDescriptionTextFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig config, TextFormatConfig formatPluginConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.elasticsearch
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.esri
ModifierConstructorDescriptionShpFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, ShpFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.excel
ModifierConstructorDescriptionExcelFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, ExcelFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.googlesheets
Modifier and TypeMethodDescriptionGoogleSheetsStoragePlugin.getConfig()
GoogleSheetsWriter.getStorage()
GoogleSheetsStoragePluginConfig.updateCredentialProvider
(CredentialsProvider credentialsProvider) ModifierConstructorDescriptionGoogleSheetsInsertWriter
(PhysicalOperator child, String sheetName, String name, StoragePluginConfig storageConfig, String queryUser, StoragePluginRegistry engineRegistry) GoogleSheetsWriter
(PhysicalOperator child, String sheetName, String name, StoragePluginConfig storageConfig, String queryUser, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.hbase
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.hdf5
ModifierConstructorDescriptionHDF5FormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, HDF5FormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.hive
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.http
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.httpd
ModifierConstructorDescriptionHttpdLogFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, HttpdLogFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.iceberg
Modifier and TypeMethodDescriptionIcebergGroupScan.getStorageConfig()
IcebergSubScan.getStorageConfig()
ModifierConstructorDescriptionIcebergGroupScan
(String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, TupleMetadata schema, String path, LogicalExpression condition, Integer maxRecords, StoragePluginRegistry pluginRegistry) IcebergSubScan
(String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, String path, List<IcebergWork> workList, TupleMetadata schema, LogicalExpression condition, Integer maxRecords, StoragePluginRegistry pluginRegistry) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.image
ModifierConstructorDescriptionImageFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, ImageFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.ischema
ModifierConstructorDescriptionInfoSchemaDrillTable
(InfoSchemaStoragePlugin plugin, String storageEngineName, InfoSchemaTableType selection, StoragePluginConfig storageEngineConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.jdbc
ModifierConstructorDescriptionJdbcInsertWriter
(PhysicalOperator child, List<String> tableIdentifier, StoragePluginConfig storageConfig, org.apache.calcite.adapter.jdbc.JdbcSchema inner, StoragePluginRegistry engineRegistry) JdbcSubScan
(String sql, List<SchemaPath> columns, StoragePluginConfig config, String username, StoragePluginRegistry plugins) JdbcWriter
(PhysicalOperator child, List<String> tableIdentifier, StoragePluginConfig storageConfig, org.apache.calcite.adapter.jdbc.JdbcSchema inner, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.kafka
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.kudu
ModifierConstructorDescriptionKuduWriter
(PhysicalOperator child, String name, StoragePluginConfig storageConfig, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.log
ModifierConstructorDescriptionLogFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, LogFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.ltsv
ModifierConstructorDescriptionLTSVFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, LTSVFormatPluginConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.mock
Modifier and TypeClassDescriptionstatic class
Each storage plugin requires a unique config class to allow config --> impl lookups to be unique.class
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.mongo
ModifierConstructorDescriptionMongoSubScan
(StoragePluginRegistry registry, String userName, StoragePluginConfig mongoPluginConfig, LinkedList<BaseMongoSubScanSpec> chunkScanSpecList, List<SchemaPath> columns) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.msaccess
ModifierConstructorDescriptionMSAccessFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, MSAccessFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.openTSDB
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.parquet
Modifier and TypeMethodDescriptionParquetGroupScan.getEngineConfig()
ParquetFormatPlugin.getStorageConfig()
ParquetRowGroupScan.getStorageConfig()
ParquetWriter.getStorageConfig()
ModifierConstructorDescriptionParquetFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig) ParquetFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, ParquetFormatConfig formatConfig) ParquetGroupScan
(StoragePluginRegistry engineRegistry, String userName, List<ReadEntryWithPath> entries, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, List<SchemaPath> columns, org.apache.hadoop.fs.Path selectionRoot, org.apache.hadoop.fs.Path cacheFileRoot, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) ParquetRowGroupScan
(StoragePluginRegistry registry, String userName, StoragePluginConfig storageConfig, FormatPluginConfig formatConfig, LinkedList<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, ParquetReaderConfig readerConfig, org.apache.hadoop.fs.Path selectionRoot, LogicalExpression filter, TupleMetadata schema) ParquetWriter
(PhysicalOperator child, String location, List<String> partitionColumns, StorageStrategy storageStrategy, StoragePluginConfig storageConfig, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.pcap.plugin
ModifierConstructorDescriptionBasePcapFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, T formatConfig) PcapFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, PcapFormatConfig formatConfig) PcapngFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, PcapngFormatConfig formatConfig) Deprecated. -
Uses of StoragePluginConfig in org.apache.drill.exec.store.pdf
ModifierConstructorDescriptionPdfFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, PdfFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.phoenix
Modifier and TypeMethodDescriptionPhoenixGroupScan.config()
PhoenixStoragePlugin.getConfig()
PhoenixSubScan.getConfig()
ModifierConstructorDescriptionPhoenixSubScan
(String userName, String sql, List<SchemaPath> columns, PhoenixScanSpec scanSpec, StoragePluginConfig config, StoragePluginRegistry registry) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.sas
ModifierConstructorDescriptionSasFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, SasFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.splunk
-
Uses of StoragePluginConfig in org.apache.drill.exec.store.spss
ModifierConstructorDescriptionSpssFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, SpssFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.sys
Modifier and TypeClassDescriptionclass
A namesake plugin configuration for system tables. -
Uses of StoragePluginConfig in org.apache.drill.exec.store.syslog
ModifierConstructorDescriptionSyslogFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, SyslogFormatConfig formatConfig) -
Uses of StoragePluginConfig in org.apache.drill.exec.store.xml
ModifierConstructorDescriptionXMLFormatPlugin
(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, XMLFormatConfig formatConfig)
StoragePluginRegistry.resolveFormat(StoragePluginConfig, FormatPluginConfig, Class)
which provides type safety.