org.apache.drill.exec.store.druid

Class DruidStoragePlugin

java.lang.Object

org.apache.drill.exec.store.AbstractStoragePlugin

org.apache.drill.exec.store.druid.DruidStoragePlugin

All Implemented Interfaces:

AutoCloseable, SchemaFactory, StoragePlugin

public class DruidStoragePlugin
extends AbstractStoragePlugin

Field Summary

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

DEFAULT_WS_NAME

Constructor Summary

Constructors

Constructor and Description
DruidStoragePlugin(DruidStoragePluginConfig pluginConfig, DrillbitContext context, String name)

Method Summary

Modifier and Type	Method and Description
DruidAdminClient	getAdminClient()
DruidStoragePluginConfig	getConfig() Method returns a Jackson serializable object that extends a StoragePluginConfig.
DrillbitContext	getContext()
DruidQueryClient	getDruidQueryClient()
Set<StoragePluginOptimizerRule>	getPhysicalOptimizerRules(OptimizerRulesContext optimizerRulesContext)
DruidGroupScan	getPhysicalScan(String userName, JSONOptions selection) Get the physical scan operator for the particular GroupScan (read) node.
ScanQueryBuilder	getScanQueryBuilder()
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.

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

close, getFormatPlugin, getLogicalOptimizerRules, getName, getOptimizerRules, getOptimizerRules, 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

DruidStoragePlugin

public DruidStoragePlugin(DruidStoragePluginConfig pluginConfig,
                          DrillbitContext context,
                          String name)

Method Detail

getPhysicalScan

public DruidGroupScan getPhysicalScan(String userName,
                                      JSONOptions selection)
                               throws IOException

Description copied from interface: StoragePlugin

Get the physical scan operator for the particular GroupScan (read) node.

Specified by:

getPhysicalScan in interface StoragePlugin

Overrides:

getPhysicalScan in class AbstractStoragePlugin

Parameters:

userName - User whom to impersonate when when reading the contents as part of Scan.

selection - The configured storage engine specific selection.

Returns:

The physical scan operator for the particular GroupScan (read) node.

Throws:

IOException

getPhysicalOptimizerRules

public Set<StoragePluginOptimizerRule> getPhysicalOptimizerRules(OptimizerRulesContext optimizerRulesContext)

Overrides:

getPhysicalOptimizerRules in class AbstractStoragePlugin

registerSchemas

public void registerSchemas(SchemaConfig schemaConfig,
                            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:

schemaConfig - Configuration for schema objects.

parent - Reference to parent schema.

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

getConfig

public DruidStoragePluginConfig getConfig()

Description copied from interface: StoragePlugin

Method returns a Jackson serializable object that extends a StoragePluginConfig.

Returns:

an extension of StoragePluginConfig

getContext

public DrillbitContext getContext()

Overrides:

getContext in class AbstractStoragePlugin

getAdminClient

public DruidAdminClient getAdminClient()

getDruidQueryClient

public DruidQueryClient getDruidQueryClient()

getScanQueryBuilder

public ScanQueryBuilder getScanQueryBuilder()