org.apache.drill.exec.store.elasticsearch

Class ElasticsearchStoragePlugin

java.lang.Object

org.apache.drill.exec.store.AbstractStoragePlugin

org.apache.drill.exec.store.elasticsearch.ElasticsearchStoragePlugin

All Implemented Interfaces:

AutoCloseable, SchemaFactory, StoragePlugin

public class ElasticsearchStoragePlugin
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
ElasticsearchStoragePlugin(ElasticsearchStorageConfig config, DrillbitContext context, String name)

Method Summary

Modifier and Type	Method and Description
ElasticsearchStorageConfig	getConfig() Method returns a Jackson serializable object that extends a StoragePluginConfig.
Set<? extends org.apache.calcite.plan.RelOptRule>	getOptimizerRules(OptimizerRulesContext optimizerContext, PlannerPhase phase) TODO: Move this method to StoragePlugin interface in next major version release.
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.

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

close, getContext, getFormatPlugin, getLogicalOptimizerRules, getName, getOptimizerRules, getPhysicalOptimizerRules, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, start, supportsWrite

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticsearchStoragePlugin

public ElasticsearchStoragePlugin(ElasticsearchStorageConfig config,
                                  DrillbitContext context,
                                  String name)

Method Detail

registerSchemas

public void registerSchemas(SchemaConfig schemaConfig,
                            org.apache.calcite.schema.SchemaPlus parent)
                     throws com.fasterxml.jackson.core.JsonProcessingException

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:

com.fasterxml.jackson.core.JsonProcessingException

getConfig

public ElasticsearchStorageConfig 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

getOptimizerRules

public Set<? extends org.apache.calcite.plan.RelOptRule> getOptimizerRules(OptimizerRulesContext optimizerContext,
                                                                           PlannerPhase phase)

Description copied from class: AbstractStoragePlugin

TODO: Move this method to StoragePlugin interface in next major version release.

Overrides:

getOptimizerRules in class AbstractStoragePlugin