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

Class Metadata_V2.ParquetTableMetadata_v2

java.lang.Object

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

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

Enclosing class:

Metadata_V2

public static class Metadata_V2.ParquetTableMetadata_v2
extends MetadataBase.ParquetTableMetadataBase

Struct which contains the metadata for an entire parquet directory structure

Field Summary

Fields

Modifier and Type	Field	Description
ConcurrentHashMap<Metadata_V2.ColumnTypeMetadata_v2.Key,Metadata_V2.ColumnTypeMetadata_v2>	columnTypeInfo

Constructor Summary

Constructors

Constructor	Description
ParquetTableMetadata_v2()
ParquetTableMetadata_v2(String metadataVersion, String drillVersion)
ParquetTableMetadata_v2(String metadataVersion, List<Metadata_V2.ParquetFileMetadata_v2> files, List<org.apache.hadoop.fs.Path> directories, ConcurrentHashMap<Metadata_V2.ColumnTypeMetadata_v2.Key,Metadata_V2.ColumnTypeMetadata_v2> columnTypeInfo, String drillVersion)
ParquetTableMetadata_v2(String metadataVersion, MetadataBase.ParquetTableMetadataBase parquetTable, List<Metadata_V2.ParquetFileMetadata_v2> files, List<org.apache.hadoop.fs.Path> directories, String drillVersion)

Method Summary

Modifier and Type	Method	Description
void	assignFiles(List<? extends MetadataBase.ParquetFileMetadata> newFiles)
MetadataBase.ParquetTableMetadataBase	clone()
Metadata_V2.ColumnTypeMetadata_v2	getColumnTypeInfo(String[] name)
List<? extends MetadataBase.ColumnTypeMetadata>	getColumnTypeInfoList()
ConcurrentHashMap<Metadata_V2.ColumnTypeMetadata_v2.Key,Metadata_V2.ColumnTypeMetadata_v2>	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)
Integer	getRepetitionLevel(String[] columnName)
Integer	getScale(String[] columnName)
boolean	hasColumnMetadata()
boolean	isRowGroupPrunable()

Methods inherited from class org.apache.drill.exec.store.parquet.metadata.MetadataBase.ParquetTableMetadataBase

getRepetition

Methods inherited from class java.lang.Object

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

Field Details

columnTypeInfo

public ConcurrentHashMap<Metadata_V2.ColumnTypeMetadata_v2.Key,Metadata_V2.ColumnTypeMetadata_v2> columnTypeInfo

Constructor Details

ParquetTableMetadata_v2

public ParquetTableMetadata_v2()

ParquetTableMetadata_v2

public ParquetTableMetadata_v2(String metadataVersion,
 String drillVersion)

ParquetTableMetadata_v2

public ParquetTableMetadata_v2(String metadataVersion,
 MetadataBase.ParquetTableMetadataBase parquetTable,
 List<Metadata_V2.ParquetFileMetadata_v2> files,
 List<org.apache.hadoop.fs.Path> directories,
 String drillVersion)

ParquetTableMetadata_v2

public ParquetTableMetadata_v2(String metadataVersion,
 List<Metadata_V2.ParquetFileMetadata_v2> files,
 List<org.apache.hadoop.fs.Path> directories,
 ConcurrentHashMap<Metadata_V2.ColumnTypeMetadata_v2.Key,Metadata_V2.ColumnTypeMetadata_v2> columnTypeInfo,
 String drillVersion)

Method Details

getColumnTypeInfo

public Metadata_V2.ColumnTypeMetadata_v2 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

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

getMetadataVersion

public String getMetadataVersion()

Specified by:

getMetadataVersion in class MetadataBase.ParquetTableMetadataBase

getColumnTypeInfoMap

public ConcurrentHashMap<Metadata_V2.ColumnTypeMetadata_v2.Key,Metadata_V2.ColumnTypeMetadata_v2> getColumnTypeInfoMap()

getColumnTypeInfoList

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

Specified by:

getColumnTypeInfoList in class MetadataBase.ParquetTableMetadataBase