Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.schema.SchemaPlus |
DynamicSchema.createRootSchema(StoragePluginRegistry storages,
SchemaConfig schemaConfig,
AliasRegistryProvider aliasRegistryProvider) |
Constructor and Description |
---|
RootSchema(StoragePluginRegistry storages) |
Modifier and Type | Method and Description |
---|---|
StoragePluginRegistry |
QueryContext.getStorage() |
Constructor and Description |
---|
PhysicalPlanReader(DrillConfig config,
ScanResult scanResult,
LogicalPlanPersistence lpPersistance,
CoordinationProtos.DrillbitEndpoint endpoint,
StoragePluginRegistry pluginRegistry) |
Constructor and Description |
---|
FileSystemCreateTableEntry(FileSystemConfig storageConfig,
FormatPluginConfig formatConfig,
String location,
List<String> partitionColumns,
StorageStrategy storageStrategy,
StoragePluginRegistry engineRegistry) |
Constructor and Description |
---|
PluginsCollector(StoragePluginRegistry storagePlugins) |
Modifier and Type | Method and Description |
---|---|
StoragePluginRegistry |
DrillbitContext.getStorage() |
Modifier and Type | Method and Description |
---|---|
void |
PluginConfigWrapper.createOrUpdateInStorage(StoragePluginRegistry storage) |
Modifier and Type | Class and Description |
---|---|
class |
StoragePluginRegistryImpl
Plugin registry.
|
Constructor and Description |
---|
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) |
Constructor and Description |
---|
DruidGroupScan(String userName,
DruidScanSpec scanSpec,
DruidStoragePluginConfig storagePluginConfig,
List<SchemaPath> columns,
int maxRecordsToRead,
StoragePluginRegistry pluginRegistry) |
DruidSubScan(StoragePluginRegistry registry,
String userName,
StoragePluginConfig config,
LinkedList<DruidSubScan.DruidSubScanSpec> datasourceScanSpecList,
List<SchemaPath> columns,
int maxRecordsToRead) |
Constructor and Description |
---|
HBaseGroupScan(String userName,
HBaseScanSpec hbaseScanSpec,
HBaseStoragePluginConfig storagePluginConfig,
List<SchemaPath> columns,
StoragePluginRegistry pluginRegistry) |
HBaseSubScan(StoragePluginRegistry registry,
String userName,
HBaseStoragePluginConfig hbaseStoragePluginConfig,
LinkedList<HBaseSubScan.HBaseSubScanSpec> regionScanSpecList,
List<SchemaPath> columns) |
Modifier and Type | Method and Description |
---|---|
StoragePluginRegistry |
HttpScanSpec.getRegistry() |
StoragePluginRegistry |
HttpStoragePlugin.getRegistry() |
Constructor and Description |
---|
HttpScanSpec(String pluginName,
String connectionName,
String tableName,
HttpStoragePluginConfig config,
PersistentTokenTable tokenTable,
StoragePluginRegistry engineRegistry) |
Constructor and Description |
---|
IcebergGroupScan(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) |
Constructor and Description |
---|
JdbcGroupScan(String sql,
List<SchemaPath> columns,
StoragePluginConfig config,
double rows,
StoragePluginRegistry plugins) |
JdbcSubScan(String sql,
List<SchemaPath> columns,
StoragePluginConfig config,
StoragePluginRegistry plugins) |
JdbcWriter(PhysicalOperator child,
String name,
StoragePluginConfig storageConfig,
org.apache.calcite.adapter.jdbc.JdbcSchema inner,
StoragePluginRegistry engineRegistry) |
Constructor and Description |
---|
KafkaGroupScan(String userName,
KafkaStoragePluginConfig kafkaStoragePluginConfig,
List<SchemaPath> columns,
KafkaScanSpec scanSpec,
StoragePluginRegistry pluginRegistry) |
KafkaSubScan(StoragePluginRegistry registry,
String userName,
KafkaStoragePluginConfig kafkaStoragePluginConfig,
List<SchemaPath> columns,
LinkedList<KafkaPartitionScanSpec> partitionSubScanSpecList) |
Constructor and Description |
---|
KuduGroupScan(KuduScanSpec kuduScanSpec,
KuduStoragePluginConfig kuduStoragePluginConfig,
List<SchemaPath> columns,
StoragePluginRegistry pluginRegistry) |
KuduSubScan(StoragePluginRegistry registry,
KuduStoragePluginConfig kuduStoragePluginConfig,
LinkedList<KuduSubScan.KuduSubScanSpec> tabletScanSpecList,
List<SchemaPath> columns) |
KuduWriter(PhysicalOperator child,
String name,
StoragePluginConfig storageConfig,
StoragePluginRegistry engineRegistry) |
Constructor and Description |
---|
MapRDBSubScan(StoragePluginRegistry engineRegistry,
String userName,
MapRDBFormatPluginConfig formatPluginConfig,
StoragePluginConfig storageConfig,
List<MapRDBSubScanSpec> regionScanSpecList,
List<SchemaPath> columns,
int maxRecordsToRead,
String tableType,
TupleMetadata schema) |
RestrictedMapRDBSubScan(StoragePluginRegistry engineRegistry,
String userName,
MapRDBFormatPluginConfig formatPluginConfig,
StoragePluginConfig storageConfig,
List<RestrictedMapRDBSubScanSpec> regionScanSpecList,
List<SchemaPath> columns,
int maxRecordsToRead,
String tableType,
TupleMetadata schema) |
Constructor and Description |
---|
BinaryTableGroupScan(String userName,
HBaseScanSpec scanSpec,
FileSystemConfig storagePluginConfig,
MapRDBFormatPluginConfig formatPluginConfig,
List<SchemaPath> columns,
TupleMetadata schema,
StoragePluginRegistry pluginRegistry) |
Constructor and Description |
---|
JsonTableGroupScan(String userName,
JsonScanSpec scanSpec,
FileSystemConfig storagePluginConfig,
MapRDBFormatPluginConfig formatPluginConfig,
List<SchemaPath> columns,
TupleMetadata schema,
StoragePluginRegistry pluginRegistry) |
Constructor and Description |
---|
MongoGroupScan(String userName,
MongoScanSpec scanSpec,
MongoStoragePluginConfig storagePluginConfig,
List<SchemaPath> columns,
boolean useAggregate,
StoragePluginRegistry pluginRegistry) |
MongoSubScan(StoragePluginRegistry registry,
String userName,
StoragePluginConfig mongoPluginConfig,
LinkedList<BaseMongoSubScanSpec> chunkScanSpecList,
List<SchemaPath> columns) |
Constructor and Description |
---|
OpenTSDBGroupScan(OpenTSDBScanSpec openTSDBScanSpec,
OpenTSDBStoragePluginConfig openTSDBStoragePluginConfig,
List<SchemaPath> columns,
StoragePluginRegistry pluginRegistry) |
OpenTSDBSubScan(StoragePluginRegistry registry,
OpenTSDBStoragePluginConfig storage,
LinkedList<OpenTSDBSubScan.OpenTSDBSubScanSpec> tabletScanSpecList,
List<SchemaPath> columns) |
Constructor and Description |
---|
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) |
Constructor and Description |
---|
PhoenixGroupScan(String userName,
String sql,
List<SchemaPath> columns,
PhoenixScanSpec scanSpec,
PhoenixStoragePluginConfig config,
StoragePluginRegistry plugins) |
PhoenixSubScan(String userName,
String sql,
List<SchemaPath> columns,
PhoenixScanSpec scanSpec,
StoragePluginConfig config,
StoragePluginRegistry registry) |
Constructor and Description |
---|
SystemTableScan(SystemTable table,
int maxRecordsToRead,
StoragePluginRegistry engineRegistry) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.