org.apache.drill.exec.store.parquet.metadata

Class MetadataBase.ParquetTableMetadataBase

java.lang.Object

org.apache.drill.exec.store.parquet.metadata.MetadataBase.ParquetTableMetadataBase

Direct Known Subclasses:

Metadata_V1.ParquetTableMetadata_v1, Metadata_V2.ParquetTableMetadata_v2, Metadata_V3.ParquetTableMetadata_v3, Metadata_V4.ParquetTableMetadata_v4

Enclosing class:

MetadataBase

public abstract static class MetadataBase.ParquetTableMetadataBase
extends Object

Basic class for parquet metadata. Inheritors of this class are json serializable structures which contain different metadata versions for an entire parquet directory structure

If any new code changes affect on the metadata files content, please update metadata version in such manner: Bump up metadata major version if metadata structure is changed. Bump up metadata minor version if only metadata content is changed, but metadata structure is the same.

Note: keep metadata versions synchronized with MetadataVersion.Constants

Constructor Summary

Constructors

Constructor and Description
ParquetTableMetadataBase()

Method Summary

Modifier and Type	Method and Description
abstract void	assignFiles(List<? extends MetadataBase.ParquetFileMetadata> newFiles)
abstract MetadataBase.ParquetTableMetadataBase	clone()
abstract List<? extends MetadataBase.ColumnTypeMetadata>	getColumnTypeInfoList()
abstract Integer	getDefinitionLevel(String[] columnName)
abstract List<org.apache.hadoop.fs.Path>	getDirectories()
abstract String	getDrillVersion()
abstract List<? extends MetadataBase.ParquetFileMetadata>	getFiles()
abstract String	getMetadataVersion()
abstract org.apache.parquet.schema.OriginalType	getOriginalType(String[] columnName)
abstract Integer	getPrecision(String[] columnName)
abstract org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName	getPrimitiveType(String[] columnName)
org.apache.parquet.schema.Type.Repetition	getRepetition(String[] columnName)
abstract Integer	getRepetitionLevel(String[] columnName)
abstract Integer	getScale(String[] columnName)
abstract boolean	hasColumnMetadata()
abstract boolean	isRowGroupPrunable()

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParquetTableMetadataBase

public ParquetTableMetadataBase()

Method Detail

getDirectories

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

getFiles

public abstract List<? extends MetadataBase.ParquetFileMetadata> getFiles()

assignFiles

public abstract void assignFiles(List<? extends MetadataBase.ParquetFileMetadata> newFiles)

hasColumnMetadata

public abstract boolean hasColumnMetadata()

getPrimitiveType

public abstract org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName getPrimitiveType(String[] columnName)

getOriginalType

public abstract org.apache.parquet.schema.OriginalType getOriginalType(String[] columnName)

getRepetitionLevel

public abstract Integer getRepetitionLevel(String[] columnName)

getDefinitionLevel

public abstract Integer getDefinitionLevel(String[] columnName)

getScale

public abstract Integer getScale(String[] columnName)

getPrecision

public abstract Integer getPrecision(String[] columnName)

isRowGroupPrunable

public abstract boolean isRowGroupPrunable()

clone

public abstract MetadataBase.ParquetTableMetadataBase clone()

Overrides:

clone in class Object

getDrillVersion

public abstract String getDrillVersion()

getMetadataVersion

public abstract String getMetadataVersion()

getColumnTypeInfoList

public abstract List<? extends MetadataBase.ColumnTypeMetadata> getColumnTypeInfoList()

getRepetition

public org.apache.parquet.schema.Type.Repetition getRepetition(String[] columnName)