public interface FormatPlugin
Modifier and Type | Method and Description |
---|---|
FormatPluginConfig |
getConfig() |
DrillbitContext |
getContext() |
org.apache.hadoop.conf.Configuration |
getFsConf() |
AbstractGroupScan |
getGroupScan(String userName,
FileSelection selection,
List<SchemaPath> columns) |
default AbstractGroupScan |
getGroupScan(String userName,
FileSelection selection,
List<SchemaPath> columns,
MetadataProviderManager metadataProviderManager) |
default AbstractGroupScan |
getGroupScan(String userName,
FileSelection selection,
List<SchemaPath> columns,
OptionManager options) |
default AbstractGroupScan |
getGroupScan(String userName,
FileSelection selection,
List<SchemaPath> columns,
OptionManager options,
MetadataProviderManager metadataProvider) |
FormatMatcher |
getMatcher() |
String |
getName() |
default Set<? extends org.apache.calcite.plan.RelOptRule> |
getOptimizerRules()
Deprecated.
|
default Set<? extends org.apache.calcite.plan.RelOptRule> |
getOptimizerRules(PlannerPhase phase) |
StoragePluginConfig |
getStorageConfig() |
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) |
boolean supportsRead()
boolean supportsWrite()
boolean supportsAutoPartitioning()
FormatMatcher getMatcher()
AbstractWriter getWriter(PhysicalOperator child, String location, List<String> partitionColumns) throws IOException
IOException
@Deprecated default Set<? extends org.apache.calcite.plan.RelOptRule> getOptimizerRules()
default Set<? extends org.apache.calcite.plan.RelOptRule> getOptimizerRules(PlannerPhase phase)
AbstractGroupScan getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns) throws IOException
IOException
default AbstractGroupScan getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options) throws IOException
IOException
default AbstractGroupScan getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager) throws IOException
IOException
default AbstractGroupScan getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, OptionManager options, MetadataProviderManager metadataProvider) throws IOException
IOException
boolean supportsStatistics()
DrillStatsTable.TableStatistics readStatistics(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath) throws IOException
IOException
void writeStatistics(DrillStatsTable.TableStatistics statistics, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath) throws IOException
IOException
FormatPluginConfig getConfig()
StoragePluginConfig getStorageConfig()
org.apache.hadoop.conf.Configuration getFsConf()
DrillbitContext getContext()
String getName()
Copyright © 1970 The Apache Software Foundation. All rights reserved.