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

Class MetastoreParquetTableMetadataProvider

java.lang.Object

org.apache.drill.exec.metastore.store.MetastoreFileTableMetadataProvider

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

All Implemented Interfaces:

ParquetMetadataProvider, ParquetTableMetadataProvider, TableMetadataProvider

public class MetastoreParquetTableMetadataProvider
extends MetastoreFileTableMetadataProvider
implements ParquetTableMetadataProvider

Implementation of TableMetadataProvider which uses Drill Metastore for providing table metadata for parquet tables.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MetastoreParquetTableMetadataProvider.Builder

Field Summary

Fields inherited from class org.apache.drill.exec.metastore.store.MetastoreFileTableMetadataProvider

basicTablesRequests, fallbackToFileMetadata, files, metastoreTableInfo, partitions, paths, schema, segmentsMetadata, statsProvider, tableInfo, tableMetadata, useSchema, useStatistics

Method Summary

Modifier and Type	Method	Description
List<ReadEntryWithPath>	getEntries()	Returns list of ReadEntryWithPath instances which represents paths to files to be scanned.
Set<org.apache.hadoop.fs.Path>	getFileSet()	Returns list of file locations for table.
List<org.apache.hadoop.fs.Path>	getLocations()	Returns list of file paths which belong to current table.
List<RowGroupMetadata>	getRowGroupsMeta()	Returns list of RowGroupMetadata instances which provides metadata for specific row group and its columns.
org.apache.drill.shaded.guava.com.google.common.collect.Multimap<org.apache.hadoop.fs.Path,RowGroupMetadata>	getRowGroupsMetadataMap()	Returns multimap of RowGroupMetadata instances which provides metadata for specific row group and its columns mapped to their locations.
org.apache.hadoop.fs.Path	getSelectionRoot()	Returns root table path.
boolean	isUsedMetadataCache()	Whether metadata cache files are used for table which belongs to current metadata provider.

Methods inherited from class org.apache.drill.exec.metastore.store.MetastoreFileTableMetadataProvider

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

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.metastore.metadata.TableMetadataProvider

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

Method Details

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

getEntries

public List<ReadEntryWithPath> getEntries()

Description copied from interface: ParquetMetadataProvider

Returns list of ReadEntryWithPath instances which represents paths to files to be scanned.

Specified by:

getEntries in interface ParquetMetadataProvider

Returns:

list of ReadEntryWithPath instances whith file paths

getRowGroupsMeta

public List<RowGroupMetadata> getRowGroupsMeta()

Description copied from interface: ParquetMetadataProvider

Returns list of RowGroupMetadata instances which provides metadata for specific row group and its columns.

Specified by:

getRowGroupsMeta in interface ParquetMetadataProvider

Returns:

list of RowGroupMetadata instances

getLocations

public List<org.apache.hadoop.fs.Path> getLocations()

Description copied from interface: ParquetMetadataProvider

Returns list of file paths which belong to current table.

Specified by:

getLocations in interface ParquetMetadataProvider

Returns:

list of file paths

getRowGroupsMetadataMap

public org.apache.drill.shaded.guava.com.google.common.collect.Multimap<org.apache.hadoop.fs.Path,RowGroupMetadata> getRowGroupsMetadataMap()

Description copied from interface: ParquetMetadataProvider

Returns multimap of RowGroupMetadata instances which provides metadata for specific row group and its columns mapped to their locations.

Specified by:

getRowGroupsMetadataMap in interface ParquetMetadataProvider

Returns:

multimap of RowGroupMetadata instances

getFileSet

public Set<org.apache.hadoop.fs.Path> getFileSet()

Description copied from interface: ParquetMetadataProvider

Returns list of file locations for table.

Specified by:

getFileSet in interface ParquetMetadataProvider

Returns:

list of file locations for table