org.apache.drill.exec.store.iceberg.format

Class IcebergFormatPlugin

java.lang.Object

org.apache.drill.exec.store.iceberg.format.IcebergFormatPlugin

All Implemented Interfaces:

FormatPlugin

public class IcebergFormatPlugin
extends Object
implements FormatPlugin

Constructor Summary

Constructors

Constructor and Description
IcebergFormatPlugin(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, FileSystemConfig storageConfig, IcebergFormatPluginConfig config)

Method Summary

Modifier and Type	Method and Description
IcebergFormatPluginConfig	getConfig()
DrillbitContext	getContext()
org.apache.calcite.plan.Convention	getConvention()
org.apache.hadoop.conf.Configuration	getFsConf()
AbstractGroupScan	getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
AbstractGroupScan	getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, MetadataProviderManager metadataProviderManager)
FormatMatcher	getMatcher()
String	getName()
Set<? extends org.apache.calcite.plan.RelOptRule>	getOptimizerRules(PlannerPhase phase)
FileSystemConfig	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)

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, getOptimizerRules

Constructor Detail

IcebergFormatPlugin

public IcebergFormatPlugin(String name,
                           DrillbitContext context,
                           org.apache.hadoop.conf.Configuration fsConf,
                           FileSystemConfig storageConfig,
                           IcebergFormatPluginConfig config)

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

getMatcher

public FormatMatcher getMatcher()

Specified by:

getMatcher in interface FormatPlugin

getWriter

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

Specified by:

getWriter in interface FormatPlugin

getOptimizerRules

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

Specified by:

getOptimizerRules in interface FormatPlugin

getGroupScan

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

Specified by:

getGroupScan in interface FormatPlugin

Throws:

IOException

getGroupScan

public AbstractGroupScan getGroupScan(String userName,
                                      FileSelection selection,
                                      List<SchemaPath> columns,
                                      MetadataProviderManager metadataProviderManager)
                               throws IOException

Specified by:

getGroupScan in interface FormatPlugin

Throws:

IOException

supportsStatistics

public boolean supportsStatistics()

Specified by:

supportsStatistics in interface FormatPlugin

readStatistics

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

Specified by:

readStatistics in interface FormatPlugin

writeStatistics

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

Specified by:

writeStatistics in interface FormatPlugin

getConfig

public IcebergFormatPluginConfig getConfig()

Specified by:

getConfig in interface FormatPlugin

getStorageConfig

public FileSystemConfig getStorageConfig()

Specified by:

getStorageConfig in interface FormatPlugin

getFsConf

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

Specified by:

getFsConf in interface FormatPlugin

getContext

public DrillbitContext getContext()

Specified by:

getContext in interface FormatPlugin

getName

public String getName()

Specified by:

getName in interface FormatPlugin

getConvention

public org.apache.calcite.plan.Convention getConvention()