org.apache.drill.exec.store.mapr

Class TableFormatPlugin

java.lang.Object

org.apache.drill.exec.store.mapr.TableFormatPlugin

All Implemented Interfaces:

FormatPlugin

Direct Known Subclasses:

MapRDBFormatPlugin, StreamsFormatPlugin

public abstract class TableFormatPlugin
extends Object
implements FormatPlugin

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TableFormatPlugin(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, TableFormatPluginConfig formatConfig)

Method Summary

Modifier and Type	Method and Description
FormatPluginConfig	getConfig()
DrillbitContext	getContext()
org.apache.hadoop.conf.Configuration	getFsConf()
com.mapr.fs.MapRFileSystem	getMaprFS()
String	getName()
Set<StoragePluginOptimizerRule>	getOptimizerRules()
StoragePluginConfig	getStorageConfig()
AbstractStoragePlugin	getStoragePlugin()
AbstractWriter	getWriter(PhysicalOperator child, String location, List<String> partitionColumns)
boolean	supportsAutoPartitioning() Indicates whether this FormatPlugin supports auto-partitioning for CTAS statements
boolean	supportsRead()
boolean	supportsWrite()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.store.dfs.FormatPlugin

getGroupScan, getGroupScan, getGroupScan, getGroupScan, getMatcher, readStatistics, supportsStatistics, writeStatistics

Constructor Detail

TableFormatPlugin

protected TableFormatPlugin(String name,
                            DrillbitContext context,
                            org.apache.hadoop.conf.Configuration fsConf,
                            StoragePluginConfig storageConfig,
                            TableFormatPluginConfig formatConfig)

Method Detail

supportsRead

public boolean supportsRead()

Specified by:

supportsRead in interface FormatPlugin

supportsWrite

public boolean supportsWrite()

Specified by:

supportsWrite in interface FormatPlugin

supportsAutoPartitioning

public boolean supportsAutoPartitioning()

Description copied from interface: FormatPlugin

Indicates whether this FormatPlugin supports auto-partitioning for CTAS statements

Specified by:

supportsAutoPartitioning in interface FormatPlugin

Returns:

true if auto-partitioning is supported

getFsConf

public org.apache.hadoop.conf.Configuration getFsConf()

Specified by:

getFsConf in interface FormatPlugin

getOptimizerRules

public Set<StoragePluginOptimizerRule> getOptimizerRules()

Specified by:

getOptimizerRules in interface FormatPlugin

getWriter

public AbstractWriter getWriter(PhysicalOperator child,
                                String location,
                                List<String> partitionColumns)
                         throws IOException

Specified by:

getWriter in interface FormatPlugin

Throws:

IOException

getConfig

public FormatPluginConfig getConfig()

Specified by:

getConfig in interface FormatPlugin

getStorageConfig

public StoragePluginConfig getStorageConfig()

Specified by:

getStorageConfig in interface FormatPlugin

getContext

public DrillbitContext getContext()

Specified by:

getContext in interface FormatPlugin

getName

public String getName()

Specified by:

getName in interface FormatPlugin

getStoragePlugin

public AbstractStoragePlugin getStoragePlugin()

getMaprFS

public com.mapr.fs.MapRFileSystem getMaprFS()