public interface StoragePlugin extends SchemaFactory, AutoCloseable
DEFAULT_WS_NAME
Modifier and Type | Method and Description |
---|---|
StoragePluginConfig |
getConfig()
Method returns a Jackson serializable object that extends a StoragePluginConfig.
|
FormatPlugin |
getFormatPlugin(FormatPluginConfig config)
Allows to get the format plugin for current storage plugin based on appropriate format plugin config usage.
|
String |
getName() |
Set<? extends org.apache.calcite.plan.RelOptRule> |
getOptimizerRules(OptimizerRulesContext optimizerContext)
Deprecated.
|
AbstractGroupScan |
getPhysicalScan(String userName,
JSONOptions selection)
Get the physical scan operator for the particular GroupScan (read) node.
|
AbstractGroupScan |
getPhysicalScan(String userName,
JSONOptions selection,
List<SchemaPath> columns)
Get the physical scan operator for the particular GroupScan (read) node.
|
AbstractGroupScan |
getPhysicalScan(String userName,
JSONOptions selection,
List<SchemaPath> columns,
SessionOptionManager options)
Get the physical scan operator for the particular GroupScan (read) node.
|
AbstractGroupScan |
getPhysicalScan(String userName,
JSONOptions selection,
List<SchemaPath> columns,
SessionOptionManager options,
MetadataProviderManager providerManager)
Get the physical scan operator for the particular GroupScan (read) node.
|
AbstractGroupScan |
getPhysicalScan(String userName,
JSONOptions selection,
SessionOptionManager options)
Get the physical scan operator for the particular GroupScan (read) node.
|
AbstractGroupScan |
getPhysicalScan(String userName,
JSONOptions selection,
SessionOptionManager options,
MetadataProviderManager providerManager)
Get the physical scan operator for the particular GroupScan (read) node.
|
void |
start()
Initialize the storage plugin.
|
boolean |
supportsRead()
Indicates if Drill can read the table from this format.
|
boolean |
supportsWrite()
Indicates if Drill can write a table to this format (e.g.
|
registerSchemas
close
String getName()
void start() throws IOException
IOException
boolean supportsRead()
boolean supportsWrite()
StoragePluginConfig getConfig()
@Deprecated Set<? extends org.apache.calcite.plan.RelOptRule> getOptimizerRules(OptimizerRulesContext optimizerContext)
AbstractGroupScan getPhysicalScan(String userName, JSONOptions selection) throws IOException
userName
- User whom to impersonate when when reading the contents as part of Scan.selection
- The configured storage engine specific selection.IOException
AbstractGroupScan getPhysicalScan(String userName, JSONOptions selection, SessionOptionManager options) throws IOException
userName
- User whom to impersonate when when reading the contents as part of Scan.selection
- The configured storage engine specific selection.options
- (optional) session optionsIOException
AbstractGroupScan getPhysicalScan(String userName, JSONOptions selection, SessionOptionManager options, MetadataProviderManager providerManager) throws IOException
userName
- User whom to impersonate when when reading the contents as part of Scan.selection
- The configured storage engine specific selection.options
- (optional) session optionsproviderManager
- manager for handling metadata providersIOException
AbstractGroupScan getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns) throws IOException
userName
- User whom to impersonate when when reading the contents as part of Scan.selection
- The configured storage engine specific selection.columns
- (optional) The list of column names to scan from the data source.IOException
AbstractGroupScan getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options) throws IOException
userName
- User whom to impersonate when when reading the contents as part of Scan.selection
- The configured storage engine specific selection.columns
- (optional) The list of column names to scan from the data source.options
- (optional) session optionsIOException
AbstractGroupScan getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options, MetadataProviderManager providerManager) throws IOException
userName
- User whom to impersonate when when reading the contents as part of Scan.selection
- The configured storage engine specific selection.columns
- (optional) The list of column names to scan from the data source.options
- (optional) session optionsproviderManager
- manager for handling metadata providersIOException
FormatPlugin getFormatPlugin(FormatPluginConfig config)
config
- format plugin configUnsupportedOperationException,
- if storage plugin doesn't support format plugins.Copyright © 1970 The Apache Software Foundation. All rights reserved.