org.apache.drill.exec.store.jdbc

Class JdbcStoragePlugin

java.lang.Object

org.apache.drill.exec.store.AbstractStoragePlugin

org.apache.drill.exec.store.jdbc.JdbcStoragePlugin

All Implemented Interfaces:

AutoCloseable, SchemaFactory, StoragePlugin

public class JdbcStoragePlugin
extends AbstractStoragePlugin

Field Summary

Fields inherited from class org.apache.drill.exec.store.AbstractStoragePlugin

context

Fields inherited from interface org.apache.drill.exec.store.SchemaFactory

DEFAULT_WS_NAME

Constructor Summary

Constructors

Constructor and Description
JdbcStoragePlugin(JdbcStorageConfig config, DrillbitContext context, String name)

Method Summary

Modifier and Type	Method and Description
void	close()
JdbcStorageConfig	getConfig() Method returns a Jackson serializable object that extends a StoragePluginConfig.
DrillJdbcConvention	getConvention()
DataSource	getDataSource()
org.apache.calcite.sql.SqlDialect	getDialect()
JdbcDialect	getJdbcDialect()
Set<org.apache.calcite.plan.RelOptRule>	getPhysicalOptimizerRules(OptimizerRulesContext context)
void	registerSchemas(SchemaConfig config, 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.

Methods inherited from class org.apache.drill.exec.store.AbstractStoragePlugin

getContext, getFormatPlugin, getLogicalOptimizerRules, getName, getOptimizerRules, getOptimizerRules, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcStoragePlugin

public JdbcStoragePlugin(JdbcStorageConfig config,
                         DrillbitContext context,
                         String name)

Method Detail

registerSchemas

public void registerSchemas(SchemaConfig config,
                            org.apache.calcite.schema.SchemaPlus parent)

Description copied from interface: SchemaFactory

Register the schemas provided by this SchemaFactory implementation under the given parent schema.

Parameters:

config - Configuration for schema objects.

parent - Reference to parent schema.

getJdbcDialect

public JdbcDialect getJdbcDialect()

getConvention

public DrillJdbcConvention getConvention()

getConfig

public JdbcStorageConfig getConfig()

Description copied from interface: StoragePlugin

Method returns a Jackson serializable object that extends a StoragePluginConfig.

Returns:

an extension of StoragePluginConfig

supportsRead

public boolean supportsRead()

Description copied from interface: StoragePlugin

Indicates if Drill can read the table from this format.

Specified by:

supportsRead in interface StoragePlugin

Overrides:

supportsRead in class AbstractStoragePlugin

supportsWrite

public boolean supportsWrite()

Description copied from interface: StoragePlugin

Indicates if Drill can write a table to this format (e.g. as JSON, csv, etc.).

Specified by:

supportsWrite in interface StoragePlugin

Overrides:

supportsWrite in class AbstractStoragePlugin

getDataSource

public DataSource getDataSource()

getDialect

public org.apache.calcite.sql.SqlDialect getDialect()

getPhysicalOptimizerRules

public Set<org.apache.calcite.plan.RelOptRule> getPhysicalOptimizerRules(OptimizerRulesContext context)

Overrides:

getPhysicalOptimizerRules in class AbstractStoragePlugin

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractStoragePlugin