| Package | Description |
|---|---|
| org.apache.drill.exec.planner | |
| org.apache.drill.exec.planner.logical | |
| org.apache.drill.exec.store | |
| org.apache.drill.exec.store.cassandra | |
| org.apache.drill.exec.store.cassandra.schema | |
| org.apache.drill.exec.store.dfs | |
| org.apache.drill.exec.store.druid | |
| org.apache.drill.exec.store.elasticsearch | |
| org.apache.drill.exec.store.elasticsearch.schema | |
| org.apache.drill.exec.store.hbase | |
| org.apache.drill.exec.store.hive | |
| org.apache.drill.exec.store.http | |
| org.apache.drill.exec.store.ischema | |
| org.apache.drill.exec.store.jdbc | |
| org.apache.drill.exec.store.kafka |
Kafka storage plugin.
|
| org.apache.drill.exec.store.kudu | |
| org.apache.drill.exec.store.mock |
Defines a mock data source which generates dummy test data for use
in testing.
|
| org.apache.drill.exec.store.mongo |
MongoDB storage plugin.
|
| org.apache.drill.exec.store.openTSDB | |
| org.apache.drill.exec.store.splunk | |
| org.apache.drill.exec.store.sys |
| Modifier and Type | Method and Description |
|---|---|
abstract org.apache.calcite.tools.RuleSet |
PlannerPhase.getRules(OptimizerRulesContext context,
Collection<StoragePlugin> plugins) |
| Modifier and Type | Method and Description |
|---|---|
StoragePlugin |
DrillTable.getPlugin() |
| Constructor and Description |
|---|
DrillTable(String storageEngineName,
StoragePlugin plugin,
Object selection)
TODO: Same purpose as other constructor except the impersonation user is the user who is running the Drillbit
process.
|
DrillTable(String storageEngineName,
StoragePlugin plugin,
org.apache.calcite.schema.Schema.TableType tableType,
String userName,
Object selection)
Creates a DrillTable instance.
|
DrillTable(String storageEngineName,
StoragePlugin plugin,
org.apache.calcite.schema.Schema.TableType tableType,
String userName,
Object selection,
MetadataProviderManager metadataProviderManager) |
DrillTable(String storageEngineName,
StoragePlugin plugin,
String userName,
Object selection)
Creates a DrillTable instance for a @{code TableType#Table} table.
|
DynamicDrillTable(StoragePlugin plugin,
String storageEngineName,
Object selection)
TODO: Same purpose as other constructor except the impersonation user is
the user who is running the Drillbit process.
|
DynamicDrillTable(StoragePlugin plugin,
String storageEngineName,
String userName,
Object selection) |
DynamicDrillTable(StoragePlugin plugin,
String storageEngineName,
String userName,
Object selection,
MetadataProviderManager metadataProviderManager) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractStoragePlugin
Abstract class for StorePlugin implementations.
|
static class |
BasePluginRegistryTest.StoragePluginFixture |
| Modifier and Type | Method and Description |
|---|---|
<T extends StoragePlugin> |
StoragePluginRegistry.resolve(StoragePluginConfig storageConfig,
Class<T> desired) |
<T extends StoragePlugin> |
StoragePluginRegistryImpl.resolve(StoragePluginConfig storageConfig,
Class<T> desired) |
| Modifier and Type | Method and Description |
|---|---|
StoragePlugin |
BasePluginRegistryTest.LocatorFixture.create(String name,
StoragePluginConfig config) |
StoragePlugin |
ClassicConnectorLocator.create(String name,
StoragePluginConfig pluginConfig)
Creates plugin instance with the given
name and configuration pluginConfig. |
StoragePlugin |
ConnectorLocator.create(String name,
StoragePluginConfig pluginConfig)
Create a connector instance given a named configuration.
|
StoragePlugin |
SystemPluginLocator.create(String name,
StoragePluginConfig pluginConfig) |
StoragePlugin |
BasePluginRegistryTest.LocatorFixture.get(String name) |
StoragePlugin |
ClassicConnectorLocator.get(String name)
Classic storage plugins do not provide default configurations.
|
StoragePlugin |
ConnectorLocator.get(String name)
Retrieve an instance of the named connector with default configuration.
|
StoragePlugin |
SystemPluginLocator.get(String name) |
StoragePlugin |
StoragePluginRegistry.getPlugin(StoragePluginConfig config)
Deprecated.
use
StoragePluginRegistry.resolve(StoragePluginConfig, Class) which provides
type safety. Retained for compatibility with older plugins |
StoragePlugin |
StoragePluginRegistryImpl.getPlugin(StoragePluginConfig config) |
StoragePlugin |
StoragePluginRegistry.getPlugin(String name)
Get a plugin by name.
|
StoragePlugin |
StoragePluginRegistryImpl.getPlugin(String name) |
StoragePlugin |
StoragePluginRegistry.getPluginByConfig(StoragePluginConfig config)
Get a plugin by configuration.
|
StoragePlugin |
StoragePluginRegistryImpl.getPluginByConfig(StoragePluginConfig config) |
StoragePlugin |
ConnectorHandle.newInstance(String name,
StoragePluginConfig config) |
StoragePlugin |
PluginHandle.plugin()
Retrieve the storage plugin instance, creating it if needed.
|
| Modifier and Type | Method and Description |
|---|---|
Class<? extends StoragePlugin> |
ConnectorHandle.connectorClass() |
Class<? extends StoragePlugin> |
BasePluginRegistryTest.LocatorFixture.connectorClassFor(Class<? extends StoragePluginConfig> configClass) |
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) |
static Map<Class<? extends StoragePluginConfig>,Constructor<? extends StoragePlugin>> |
ClassicConnectorLocator.constuctorsFor(Class<? extends StoragePlugin> plugin) |
Collection<StoragePlugin> |
BasePluginRegistryTest.LocatorFixture.intrinsicPlugins() |
List<StoragePlugin> |
ClassicConnectorLocator.intrinsicPlugins() |
Collection<StoragePlugin> |
ConnectorLocator.intrinsicPlugins()
Enumerate the intrinsic plugins.
|
Collection<StoragePlugin> |
SystemPluginLocator.intrinsicPlugins() |
Iterator<Map.Entry<String,StoragePlugin>> |
StoragePluginRegistryImpl.iterator() |
| Modifier and Type | Method and Description |
|---|---|
static ConnectorHandle |
ConnectorHandle.intrinsicConnector(ConnectorLocator locator,
StoragePlugin plugin)
Construct a handle for an intrinsic (system) connector which always
uses a single config: the one created along with the plugin instance
itself.
|
| Modifier and Type | Method and Description |
|---|---|
static Map<Class<? extends StoragePluginConfig>,Constructor<? extends StoragePlugin>> |
ClassicConnectorLocator.constuctorsFor(Class<? extends StoragePlugin> plugin) |
| Constructor and Description |
|---|
PluginHandle(StoragePlugin plugin,
ConnectorHandle connector,
org.apache.drill.exec.store.PluginHandle.PluginType type) |
| Modifier and Type | Class and Description |
|---|---|
class |
CassandraStoragePlugin |
| Constructor and Description |
|---|
CassandraDrillSchema(String name,
StoragePlugin plugin,
org.apache.calcite.adapter.cassandra.CassandraSchema delegatingSchema) |
CassandraDynamicTable(StoragePlugin plugin,
String storageEngineName,
Object selection,
org.apache.calcite.adapter.cassandra.CassandraTable table) |
CassandraRootDrillSchema(String name,
StoragePlugin plugin,
org.apache.calcite.schema.SchemaFactory schemaFactory,
org.apache.calcite.schema.SchemaPlus parent,
String parentName,
Map<String,Object> configMap) |
| Modifier and Type | Class and Description |
|---|---|
class |
FileSystemPlugin
A Storage engine associated with a Hadoop FileSystem Implementation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DruidStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
ElasticsearchStoragePlugin |
| Constructor and Description |
|---|
ElasticsearchDrillSchema(String name,
StoragePlugin plugin,
org.apache.calcite.schema.Schema delegatingSchema) |
ElasticsearchDynamicTable(StoragePlugin plugin,
String storageEngineName,
Object selection,
org.apache.calcite.schema.Table table) |
| Modifier and Type | Class and Description |
|---|---|
class |
HBaseStoragePlugin |
| Constructor and Description |
|---|
AbstractHBaseDrillTable(String storageEngineName,
StoragePlugin plugin,
Object selection) |
| Modifier and Type | Class and Description |
|---|---|
class |
HiveStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
HttpStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
InfoSchemaStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
JdbcStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
KuduStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
MockBreakageStorage |
class |
MockStorageEngine |
| Modifier and Type | Class and Description |
|---|---|
class |
MongoStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
OpenTSDBStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
SplunkStoragePlugin |
| Modifier and Type | Class and Description |
|---|---|
class |
SystemTablePlugin
A "storage" plugin for system tables.
|
| Constructor and Description |
|---|
StaticDrillTable(String storageEngineName,
StoragePlugin plugin,
org.apache.calcite.schema.Schema.TableType tableType,
Object selection,
RecordDataType dataType) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.