org.apache.drill.exec.store.hive

Class HiveStoragePlugin

java.lang.Object

org.apache.drill.exec.store.AbstractStoragePlugin

org.apache.drill.exec.store.hive.HiveStoragePlugin

All Implemented Interfaces:

AutoCloseable, SchemaFactory, StoragePlugin

public class HiveStoragePlugin
extends AbstractStoragePlugin

Field Summary

Fields

Modifier and Type	Field and Description
static String	HIVE_MAPRDB_FORMAT_PLUGIN_NAME

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
HiveStoragePlugin(HiveStoragePluginConfig config, DrillbitContext context, String name)

Method Summary

Modifier and Type	Method and Description
HiveStoragePluginConfig	getConfig() Method returns a Jackson serializable object that extends a StoragePluginConfig.
FormatPlugin	getFormatPlugin(FormatPluginConfig formatConfig) Allows to get the format plugin for current storage plugin based on appropriate format plugin config usage.
org.apache.hadoop.hive.conf.HiveConf	getHiveConf()
Set<StoragePluginOptimizerRule>	getLogicalOptimizerRules(OptimizerRulesContext optimizerContext)
Set<StoragePluginOptimizerRule>	getPhysicalOptimizerRules(OptimizerRulesContext optimizerRulesContext)
HiveScan	getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns) Get the physical scan operator for the particular GroupScan (read) node.
HiveScan	getPhysicalScan(String userName, JSONOptions selection, List<SchemaPath> columns, SessionOptionManager options) Get the physical scan operator for the particular GroupScan (read) node.
HiveScan	getPhysicalScan(String userName, JSONOptions selection, SessionOptionManager options) 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.

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

close, getContext, getName, getOptimizerRules, getOptimizerRules, getPhysicalScan, getPhysicalScan, getPhysicalScan, start, supportsRead, supportsWrite

Methods inherited from class java.lang.Object

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

Field Detail

HIVE_MAPRDB_FORMAT_PLUGIN_NAME

public static final String HIVE_MAPRDB_FORMAT_PLUGIN_NAME

See Also:

Constant Field Values

Constructor Detail

HiveStoragePlugin

public HiveStoragePlugin(HiveStoragePluginConfig config,
                         DrillbitContext context,
                         String name)
                  throws ExecutionSetupException

Throws:

ExecutionSetupException

Method Detail

getHiveConf

public org.apache.hadoop.hive.conf.HiveConf getHiveConf()

getConfig

public HiveStoragePluginConfig getConfig()

Description copied from interface: StoragePlugin

Method returns a Jackson serializable object that extends a StoragePluginConfig.

Returns:

an extension of StoragePluginConfig

getPhysicalScan

public HiveScan getPhysicalScan(String userName,
                                JSONOptions selection,
                                SessionOptionManager options)
                         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.

options - (optional) session options

Returns:

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

Throws:

IOException

getPhysicalScan

public HiveScan getPhysicalScan(String userName,
                                JSONOptions selection,
                                List<SchemaPath> columns)
                         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.

columns - (optional) The list of column names to scan from the data source.

Returns:

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

Throws:

IOException

getPhysicalScan

public HiveScan getPhysicalScan(String userName,
                                JSONOptions selection,
                                List<SchemaPath> columns,
                                SessionOptionManager options)
                         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.

columns - (optional) The list of column names to scan from the data source.

options - (optional) session options

Returns:

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

Throws:

IOException

registerSchemas

public void registerSchemas(SchemaConfig schemaConfig,
                            org.apache.calcite.schema.SchemaPlus parent)
                     throws IOException

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.

Throws:

IOException - in case of error during schema registration

getLogicalOptimizerRules

public Set<StoragePluginOptimizerRule> getLogicalOptimizerRules(OptimizerRulesContext optimizerContext)

Overrides:

getLogicalOptimizerRules in class AbstractStoragePlugin

getPhysicalOptimizerRules

public Set<StoragePluginOptimizerRule> getPhysicalOptimizerRules(OptimizerRulesContext optimizerRulesContext)

Overrides:

getPhysicalOptimizerRules in class AbstractStoragePlugin

getFormatPlugin

public FormatPlugin getFormatPlugin(FormatPluginConfig formatConfig)

Description copied from interface: StoragePlugin

Allows to get the format plugin for current storage plugin based on appropriate format plugin config usage.

Specified by:

getFormatPlugin in interface StoragePlugin

Overrides:

getFormatPlugin in class AbstractStoragePlugin

Parameters:

formatConfig - format plugin config

Returns:

format plugin instance