org.apache.drill.exec.store.parquet.columnreaders

Class ParquetColumnMetadata

java.lang.Object

org.apache.drill.exec.store.parquet.columnreaders.ParquetColumnMetadata

public class ParquetColumnMetadata
extends Object

Represents a single column read from the Parquet file by the record reader.

Field Summary

Fields

Modifier and Type	Field and Description
static int	UNDEFINED_LENGTH

Constructor Summary

Constructors

Constructor and Description
ParquetColumnMetadata(org.apache.parquet.column.ColumnDescriptor column)

Method Summary

Modifier and Type	Method and Description
int	getDataTypeLength() Returns data type length for a given ColumnDescriptor and it's corresponding SchemaElement.
MaterializedField	getField()
static int	getTypeLengthInBits(org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName type)
boolean	isFixedLength()
boolean	isRepeated()
void	resolveDrillType(Map<String,org.apache.parquet.format.SchemaElement> schemaElements, OptionManager options)

Methods inherited from class java.lang.Object

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

Field Detail

UNDEFINED_LENGTH

public static final int UNDEFINED_LENGTH

See Also:

Constant Field Values

Constructor Detail

ParquetColumnMetadata

public ParquetColumnMetadata(org.apache.parquet.column.ColumnDescriptor column)

Method Detail

resolveDrillType

public void resolveDrillType(Map<String,org.apache.parquet.format.SchemaElement> schemaElements,
                             OptionManager options)

getTypeLengthInBits

public static int getTypeLengthInBits(org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName type)

Parameters:

type -

type - a fixed length type from the parquet library enum

Returns:

the length in pageDataByteArray of the type

getDataTypeLength

public int getDataTypeLength()

Returns data type length for a given ColumnDescriptor and it's corresponding SchemaElement. Neither is enough information alone as the max repetition level (indicating if it is an array type) is in the ColumnDescriptor and the length of a fixed width field is stored at the schema level.

Returns:

the length if fixed width, else UNDEFINED_LENGTH (-1)

isFixedLength

public boolean isFixedLength()

isRepeated

public boolean isRepeated()

getField

public MaterializedField getField()