org.apache.drill.exec.metastore.store.parquet

Class ParquetTableMetadataProviderImpl

java.lang.Object

org.apache.drill.exec.store.parquet.BaseParquetMetadataProvider

org.apache.drill.exec.metastore.store.parquet.ParquetTableMetadataProviderImpl

All Implemented Interfaces:

ParquetMetadataProvider, ParquetTableMetadataProvider, TableMetadataProvider

public class ParquetTableMetadataProviderImpl
extends BaseParquetMetadataProvider
implements ParquetTableMetadataProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ParquetTableMetadataProviderImpl.Builder

Field Summary

Fields inherited from class org.apache.drill.exec.store.parquet.BaseParquetMetadataProvider

entries, fileSet, NULL_VALUE, parquetTableMetadata, readerConfig, schema, statsTable, tableLocation, tableName

Method Summary

Modifier and Type	Method and Description
boolean	fileExists(DrillFileSystem fs, List<org.apache.hadoop.fs.Path> paths)
org.apache.hadoop.fs.Path	getSelectionRoot() Returns root table path.
protected void	initInternal()
boolean	isUsedMetadataCache() Whether metadata cache files are used for table which belongs to current metadata provider.
List<org.apache.hadoop.fs.Path>	populateMetaPaths(org.apache.hadoop.fs.Path p, DrillFileSystem fs) Returns list of metadata cache files

Methods inherited from class org.apache.drill.exec.store.parquet.BaseParquetMetadataProvider

checkMetadataVersion, getEntries, getFileMetadata, getFileSet, getFilesForPartition, getFilesMetadataMap, getLocations, getNonInterestingColumnsMetadata, getPartitionColumns, getPartitionMetadata, getPartitionsMetadata, getRowGroupsMeta, getRowGroupsMetadataMap, getSegmentsMetadataMap, getTableMetadata, init, initializeMetadata

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.metastore.store.parquet.ParquetMetadataProvider

getEntries, getFileSet, getLocations, getRowGroupsMeta, getRowGroupsMetadataMap

Methods inherited from interface org.apache.drill.metastore.metadata.TableMetadataProvider

checkMetadataVersion, getFileMetadata, getFilesForPartition, getFilesMetadataMap, getNonInterestingColumnsMetadata, getPartitionColumns, getPartitionMetadata, getPartitionsMetadata, getSegmentsMetadataMap, getTableMetadata

Method Detail

isUsedMetadataCache

public boolean isUsedMetadataCache()

Description copied from interface: ParquetTableMetadataProvider

Whether metadata cache files are used for table which belongs to current metadata provider.

Specified by:

isUsedMetadataCache in interface ParquetTableMetadataProvider

Returns:

true if metadata cache files are used

getSelectionRoot

public org.apache.hadoop.fs.Path getSelectionRoot()

Description copied from interface: ParquetTableMetadataProvider

Returns root table path.

Specified by:

getSelectionRoot in interface ParquetTableMetadataProvider

Returns:

root path of the table

populateMetaPaths

public List<org.apache.hadoop.fs.Path> populateMetaPaths(org.apache.hadoop.fs.Path p,
                                                         DrillFileSystem fs)
                                                  throws IOException

Returns list of metadata cache files

Parameters:

p - directory path of the cache file

fs - filesystem object

Returns:

list of cache files found in the given directory path

Throws:

IOException

fileExists

public boolean fileExists(DrillFileSystem fs,
                          List<org.apache.hadoop.fs.Path> paths)
                   throws IOException

Throws:

IOException

initInternal

protected void initInternal()
                     throws IOException

Specified by:

initInternal in class BaseParquetMetadataProvider

Throws:

IOException