public class KuduStoragePlugin extends AbstractStoragePlugin
context
DEFAULT_WS_NAME
Constructor and Description |
---|
KuduStoragePlugin(KuduStoragePluginConfig configuration,
DrillbitContext context,
String name) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.kudu.client.KuduClient |
getClient() |
KuduStoragePluginConfig |
getConfig()
Method returns a Jackson serializable object that extends a StoragePluginConfig.
|
KuduGroupScan |
getPhysicalScan(String userName,
JSONOptions selection)
Get the physical scan operator for the particular GroupScan (read) node.
|
void |
registerSchemas(SchemaConfig schemaConfig,
org.apache.calcite.schema.SchemaPlus parent)
Register the schemas provided by this SchemaFactory implementation under the given parent schema.
|
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.
|
getContext, getFormatPlugin, getLogicalOptimizerRules, getName, getOptimizerRules, getOptimizerRules, getPhysicalOptimizerRules, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, start
public KuduStoragePlugin(KuduStoragePluginConfig configuration, DrillbitContext context, String name) throws IOException
IOException
public org.apache.kudu.client.KuduClient getClient()
public void close() throws Exception
close
in interface AutoCloseable
close
in class AbstractStoragePlugin
Exception
public boolean supportsRead()
StoragePlugin
supportsRead
in interface StoragePlugin
supportsRead
in class AbstractStoragePlugin
public KuduGroupScan getPhysicalScan(String userName, JSONOptions selection) throws IOException
StoragePlugin
getPhysicalScan
in interface StoragePlugin
getPhysicalScan
in class AbstractStoragePlugin
userName
- User whom to impersonate when when reading the contents as part of Scan.selection
- The configured storage engine specific selection.IOException
public boolean supportsWrite()
StoragePlugin
supportsWrite
in interface StoragePlugin
supportsWrite
in class AbstractStoragePlugin
public void registerSchemas(SchemaConfig schemaConfig, org.apache.calcite.schema.SchemaPlus parent) throws IOException
SchemaFactory
schemaConfig
- Configuration for schema objects.parent
- Reference to parent schema.IOException
- in case of error during schema registrationpublic KuduStoragePluginConfig getConfig()
StoragePlugin
Copyright © 2022 The Apache Software Foundation. All rights reserved.