org.apache.drill.exec.store.mapr.streams

Class StreamsFormatPlugin

java.lang.Object

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

org.apache.drill.exec.store.mapr.streams.StreamsFormatPlugin

All Implemented Interfaces:

FormatPlugin

public class StreamsFormatPlugin
extends TableFormatPlugin

Constructor Summary

Constructors

Constructor and Description
StreamsFormatPlugin(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, StreamsFormatPluginConfig formatConfig)

Method Summary

Modifier and Type	Method and Description
AbstractGroupScan	getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
FormatMatcher	getMatcher()
AbstractWriter	getWriter(PhysicalOperator child, String location, List<String> partitionColumns)
DrillStatsTable.TableStatistics	readStatistics(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath)
boolean	supportsAutoPartitioning() Indicates whether this FormatPlugin supports auto-partitioning for CTAS statements
boolean	supportsRead()
boolean	supportsStatistics()
boolean	supportsWrite()
void	writeStatistics(DrillStatsTable.TableStatistics statistics, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath)

Methods inherited from class org.apache.drill.exec.store.mapr.TableFormatPlugin

getConfig, getContext, getFsConf, getMaprFS, getName, getOptimizerRules, getStorageConfig, getStoragePlugin

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

Constructor Detail

StreamsFormatPlugin

public StreamsFormatPlugin(String name,
                           DrillbitContext context,
                           org.apache.hadoop.conf.Configuration fsConf,
                           StoragePluginConfig storageConfig,
                           StreamsFormatPluginConfig formatConfig)

Method Detail

supportsRead

public boolean supportsRead()

Specified by:

supportsRead in interface FormatPlugin

Overrides:

supportsRead in class TableFormatPlugin

supportsWrite

public boolean supportsWrite()

Specified by:

supportsWrite in interface FormatPlugin

Overrides:

supportsWrite in class TableFormatPlugin

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

Overrides:

supportsAutoPartitioning in class TableFormatPlugin

Returns:

true if auto-partitioning is supported

getMatcher

public FormatMatcher getMatcher()

getWriter

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

Specified by:

getWriter in interface FormatPlugin

Overrides:

getWriter in class TableFormatPlugin

Throws:

IOException

getGroupScan

public AbstractGroupScan getGroupScan(String userName,
                                      FileSelection selection,
                                      List<SchemaPath> columns)

supportsStatistics

public boolean supportsStatistics()

readStatistics

public DrillStatsTable.TableStatistics readStatistics(org.apache.hadoop.fs.FileSystem fs,
                                                      org.apache.hadoop.fs.Path statsTablePath)

writeStatistics

public void writeStatistics(DrillStatsTable.TableStatistics statistics,
                            org.apache.hadoop.fs.FileSystem fs,
                            org.apache.hadoop.fs.Path statsTablePath)