Uses of Interface
org.apache.drill.exec.store.StoragePluginRegistry
Package
Description
Kafka storage plugin.
MongoDB storage plugin.
-
Uses of StoragePluginRegistry in org.apache.calcite.jdbc
Modifier and TypeMethodDescriptionstatic org.apache.calcite.schema.SchemaPlus
DynamicSchema.createRootSchema
(StoragePluginRegistry storages, SchemaConfig schemaConfig, AliasRegistryProvider aliasRegistryProvider) -
Uses of StoragePluginRegistry in org.apache.drill.exec.ops
-
Uses of StoragePluginRegistry in org.apache.drill.exec.planner
ModifierConstructorDescriptionPhysicalPlanReader
(DrillConfig config, ScanResult scanResult, LogicalPlanPersistence lpPersistance, CoordinationProtos.DrillbitEndpoint endpoint, StoragePluginRegistry pluginRegistry) -
Uses of StoragePluginRegistry in org.apache.drill.exec.planner.logical
ModifierConstructorDescriptionFileSystemCreateTableEntry
(FileSystemConfig storageConfig, FormatPluginConfig formatConfig, String location, List<String> partitionColumns, StorageStrategy storageStrategy, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginRegistry in org.apache.drill.exec.planner.sql.handlers
-
Uses of StoragePluginRegistry in org.apache.drill.exec.server
-
Uses of StoragePluginRegistry in org.apache.drill.exec.server.rest
Modifier and TypeMethodDescriptionvoid
PluginConfigWrapper.createOrUpdateInStorage
(StoragePluginRegistry storage) static javax.ws.rs.core.Response
OAuthRequests.updateAccessToken
(String name, OAuthTokenContainer tokens, StoragePluginRegistry storage, DrillRestServer.UserAuthEnabled authEnabled, javax.ws.rs.core.SecurityContext sc) static javax.ws.rs.core.Response
OAuthRequests.updateAuthToken
(String name, String code, javax.servlet.http.HttpServletRequest request, StoragePluginRegistry storage, DrillRestServer.UserAuthEnabled authEnabled, javax.ws.rs.core.SecurityContext sc) static javax.ws.rs.core.Response
OAuthRequests.updateOAuthTokens
(String name, OAuthTokenContainer tokenContainer, StoragePluginRegistry storage, DrillRestServer.UserAuthEnabled authEnabled, javax.ws.rs.core.SecurityContext sc) static javax.ws.rs.core.Response
OAuthRequests.updateRefreshToken
(String name, OAuthTokenContainer tokens, StoragePluginRegistry storage, DrillRestServer.UserAuthEnabled authEnabled, javax.ws.rs.core.SecurityContext sc) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store
-
Uses of StoragePluginRegistry in org.apache.drill.exec.store.delta
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 StoragePluginRegistry in org.apache.drill.exec.store.dfs.easy
ModifierConstructorDescriptionEasyGroupScan
(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 StoragePluginRegistry in org.apache.drill.exec.store.druid
ModifierConstructorDescriptionDruidGroupScan
(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) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.googlesheets
ModifierConstructorDescriptionGoogleSheetsGroupScan
(String userName, GoogleSheetsScanSpec scanSpec, List<SchemaPath> columns, Map<String, ExprNode.ColRelOpConstNode> filters, double selectivity, int maxRecords, StoragePluginRegistry plugins) GoogleSheetsInsertWriter
(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 StoragePluginRegistry in org.apache.drill.exec.store.hbase
ModifierConstructorDescriptionHBaseGroupScan
(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) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.hive
ModifierConstructorDescriptionHiveDrillNativeParquetRowGroupScan
(StoragePluginRegistry registry, String userName, HiveStoragePluginConfig hiveStoragePluginConfig, List<RowGroupReadEntry> rowGroupReadEntries, List<SchemaPath> columns, HivePartitionHolder hivePartitionHolder, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) HiveDrillNativeParquetScan
(StoragePluginRegistry engineRegistry, String userName, HiveStoragePluginConfig hiveStoragePluginConfig, List<SchemaPath> columns, List<ReadEntryWithPath> entries, HivePartitionHolder hivePartitionHolder, Map<String, String> confProperties, ParquetReaderConfig readerConfig, LogicalExpression filter, TupleMetadata schema) HiveScan
(String userName, HiveReadEntry hiveReadEntry, HiveStoragePluginConfig hiveStoragePluginConfig, List<SchemaPath> columns, Map<String, String> confProperties, StoragePluginRegistry pluginRegistry) HiveSubScan
(StoragePluginRegistry registry, String userName, List<List<String>> splits, HiveReadEntry hiveReadEntry, List<String> splitClasses, List<SchemaPath> columns, HiveStoragePluginConfig hiveStoragePluginConfig, Map<String, String> confProperties) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.http
ModifierConstructorDescriptionHttpScanSpec
(String pluginName, String connectionName, String tableName, HttpStoragePluginConfig config, PersistentTokenTable tokenTable, String queryUserName, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.iceberg
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 StoragePluginRegistry in org.apache.drill.exec.store.jdbc
ModifierConstructorDescriptionJdbcGroupScan
(String sql, List<SchemaPath> columns, JdbcStorageConfig config, double rows, String username, StoragePluginRegistry plugins) JdbcInsertWriter
(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 StoragePluginRegistry in org.apache.drill.exec.store.kafka
ModifierConstructorDescriptionKafkaGroupScan
(String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, int records, KafkaScanSpec scanSpec, StoragePluginRegistry pluginRegistry) KafkaSubScan
(StoragePluginRegistry registry, String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, int records, LinkedList<KafkaPartitionScanSpec> partitionSubScanSpecList) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.kudu
ModifierConstructorDescriptionKuduGroupScan
(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) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.mongo
ModifierConstructorDescriptionMongoGroupScan
(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) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.openTSDB
ModifierConstructorDescriptionOpenTSDBGroupScan
(OpenTSDBScanSpec openTSDBScanSpec, OpenTSDBStoragePluginConfig openTSDBStoragePluginConfig, List<SchemaPath> columns, StoragePluginRegistry pluginRegistry) OpenTSDBSubScan
(StoragePluginRegistry registry, OpenTSDBStoragePluginConfig storage, LinkedList<OpenTSDBSubScan.OpenTSDBSubScanSpec> tabletScanSpecList, List<SchemaPath> columns) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.parquet
ModifierConstructorDescriptionParquetGroupScan
(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 StoragePluginRegistry in org.apache.drill.exec.store.phoenix
ModifierConstructorDescriptionPhoenixGroupScan
(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) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.splunk
ModifierConstructorDescriptionSplunkInsertWriter
(PhysicalOperator child, List<String> tableIdentifier, SplunkPluginConfig storageConfig, StoragePluginRegistry pluginRegistry) SplunkWriter
(PhysicalOperator child, List<String> tableIdentifier, SplunkPluginConfig storageConfig, StoragePluginRegistry engineRegistry) -
Uses of StoragePluginRegistry in org.apache.drill.exec.store.sys
ModifierConstructorDescriptionSystemTableScan
(SystemTable table, int maxRecordsToRead, StoragePluginRegistry engineRegistry)