public class StreamsFormatPlugin extends TableFormatPlugin
| Constructor and Description |
|---|
StreamsFormatPlugin(String name,
DrillbitContext context,
org.apache.hadoop.conf.Configuration fsConf,
StoragePluginConfig storageConfig,
StreamsFormatPluginConfig formatConfig) |
| 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) |
getConfig, getContext, getFsConf, getMaprFS, getName, getOptimizerRules, getStorageConfig, getStoragePluginclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetGroupScan, getGroupScan, getGroupScanpublic StreamsFormatPlugin(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, StreamsFormatPluginConfig formatConfig)
public boolean supportsRead()
supportsRead in interface FormatPluginsupportsRead in class TableFormatPluginpublic boolean supportsWrite()
supportsWrite in interface FormatPluginsupportsWrite in class TableFormatPluginpublic boolean supportsAutoPartitioning()
FormatPluginsupportsAutoPartitioning in interface FormatPluginsupportsAutoPartitioning in class TableFormatPluginpublic FormatMatcher getMatcher()
public AbstractWriter getWriter(PhysicalOperator child, String location, List<String> partitionColumns) throws IOException
getWriter in interface FormatPlugingetWriter in class TableFormatPluginIOExceptionpublic AbstractGroupScan getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
public boolean supportsStatistics()
public DrillStatsTable.TableStatistics readStatistics(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath)
public void writeStatistics(DrillStatsTable.TableStatistics statistics, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath)
Copyright © 2021 The Apache Software Foundation. All rights reserved.