Package 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 Details

    • ParquetTableMetadataBase

      public ParquetTableMetadataBase()

  • Method Details

    • 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)