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

Class Metadata_V4.ParquetTableMetadata_v4

java.lang.Object

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

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

Enclosing class:

Metadata_V4

public static class Metadata_V4.ParquetTableMetadata_v4
extends MetadataBase.ParquetTableMetadataBase

Constructor Summary

Constructors

Constructor and Description
ParquetTableMetadata_v4()
ParquetTableMetadata_v4(Metadata_V4.MetadataSummary metadataSummary)
ParquetTableMetadata_v4(Metadata_V4.MetadataSummary metadataSummary, Metadata_V4.FileMetadata fileMetadata)
ParquetTableMetadata_v4(String metadataVersion, MetadataBase.ParquetTableMetadataBase parquetTableMetadata, List<Metadata_V4.ParquetFileMetadata_v4> files, List<org.apache.hadoop.fs.Path> directories, String drillVersion, long totalRowCount, boolean allColumnsInteresting)

Method Summary

Modifier and Type	Method and Description
void	assignFiles(List<? extends MetadataBase.ParquetFileMetadata> newFiles)
MetadataBase.ParquetTableMetadataBase	clone()
Metadata_V4.ColumnTypeMetadata_v4	getColumnTypeInfo(String[] name)
List<? extends MetadataBase.ColumnTypeMetadata>	getColumnTypeInfoList()
ConcurrentHashMap<Metadata_V4.ColumnTypeMetadata_v4.Key,Metadata_V4.ColumnTypeMetadata_v4>	getColumnTypeInfoMap()
Integer	getDefinitionLevel(String[] columnName)
List<org.apache.hadoop.fs.Path>	getDirectories()
String	getDrillVersion()
List<? extends MetadataBase.ParquetFileMetadata>	getFiles()
String	getMetadataVersion()
org.apache.parquet.schema.OriginalType	getOriginalType(String[] columnName)
Integer	getPrecision(String[] columnName)
org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName	getPrimitiveType(String[] columnName)
org.apache.parquet.schema.Type.Repetition	getRepetition(String[] columnName)
Integer	getRepetitionLevel(String[] columnName)
Integer	getScale(String[] columnName)
Metadata_V4.MetadataSummary	getSummary()
long	getTotalNullCount(String[] columnName)
long	getTotalRowCount()
boolean	hasColumnMetadata()
boolean	isAllColumnsInteresting()
boolean	isRowGroupPrunable()
void	setTotalRowCount(long totalRowCount)
void	updateRelativePaths(String baseDir) If directories list and file metadata list contain relative paths, update it to absolute ones

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetTableMetadata_v4

public ParquetTableMetadata_v4()

ParquetTableMetadata_v4

public ParquetTableMetadata_v4(Metadata_V4.MetadataSummary metadataSummary)

ParquetTableMetadata_v4

public ParquetTableMetadata_v4(Metadata_V4.MetadataSummary metadataSummary,
                               Metadata_V4.FileMetadata fileMetadata)

ParquetTableMetadata_v4

public ParquetTableMetadata_v4(String metadataVersion,
                               MetadataBase.ParquetTableMetadataBase parquetTableMetadata,
                               List<Metadata_V4.ParquetFileMetadata_v4> files,
                               List<org.apache.hadoop.fs.Path> directories,
                               String drillVersion,
                               long totalRowCount,
                               boolean allColumnsInteresting)

Method Detail

getColumnTypeInfo

public Metadata_V4.ColumnTypeMetadata_v4 getColumnTypeInfo(String[] name)

getDirectories

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

Specified by:

getDirectories in class MetadataBase.ParquetTableMetadataBase

getFiles

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

Specified by:

getFiles in class MetadataBase.ParquetTableMetadataBase

getMetadataVersion

public String getMetadataVersion()

Specified by:

getMetadataVersion in class MetadataBase.ParquetTableMetadataBase

updateRelativePaths

public void updateRelativePaths(String baseDir)

If directories list and file metadata list contain relative paths, update it to absolute ones

Parameters:

baseDir - base parent directory

assignFiles

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

Specified by:

assignFiles in class MetadataBase.ParquetTableMetadataBase

hasColumnMetadata

public boolean hasColumnMetadata()

Specified by:

hasColumnMetadata in class MetadataBase.ParquetTableMetadataBase

getPrimitiveType

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

Specified by:

getPrimitiveType in class MetadataBase.ParquetTableMetadataBase

getOriginalType

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

Specified by:

getOriginalType in class MetadataBase.ParquetTableMetadataBase

getRepetitionLevel

public Integer getRepetitionLevel(String[] columnName)

Specified by:

getRepetitionLevel in class MetadataBase.ParquetTableMetadataBase

getDefinitionLevel

public Integer getDefinitionLevel(String[] columnName)

Specified by:

getDefinitionLevel in class MetadataBase.ParquetTableMetadataBase

getScale

public Integer getScale(String[] columnName)

Specified by:

getScale in class MetadataBase.ParquetTableMetadataBase

getPrecision

public Integer getPrecision(String[] columnName)

Specified by:

getPrecision in class MetadataBase.ParquetTableMetadataBase

isRowGroupPrunable

public boolean isRowGroupPrunable()

Specified by:

isRowGroupPrunable in class MetadataBase.ParquetTableMetadataBase

clone

public MetadataBase.ParquetTableMetadataBase clone()

Specified by:

clone in class MetadataBase.ParquetTableMetadataBase

getDrillVersion

public String getDrillVersion()

Specified by:

getDrillVersion in class MetadataBase.ParquetTableMetadataBase

getRepetition

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

Overrides:

getRepetition in class MetadataBase.ParquetTableMetadataBase

getSummary

public Metadata_V4.MetadataSummary getSummary()

getTotalRowCount

public long getTotalRowCount()

getTotalNullCount

public long getTotalNullCount(String[] columnName)

isAllColumnsInteresting

public boolean isAllColumnsInteresting()

getColumnTypeInfoMap

public ConcurrentHashMap<Metadata_V4.ColumnTypeMetadata_v4.Key,Metadata_V4.ColumnTypeMetadata_v4> getColumnTypeInfoMap()

getColumnTypeInfoList

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

Specified by:

getColumnTypeInfoList in class MetadataBase.ParquetTableMetadataBase

setTotalRowCount

public void setTotalRowCount(long totalRowCount)