Class ParquetDataColumnReaderFactory.TypesFromInt96PageReader
- java.lang.Object
-
- org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
-
- org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.TypesFromInt96PageReader
-
- All Implemented Interfaces:
ParquetDataColumnReader
- Enclosing class:
- ParquetDataColumnReaderFactory
public static class ParquetDataColumnReaderFactory.TypesFromInt96PageReader extends ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
The reader who reads from the underlying Timestamp value.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
dict, valuesReader
-
-
Constructor Summary
Constructors Constructor Description TypesFromInt96PageReader(org.apache.parquet.column.Dictionary dict, boolean isUtcTimestamp)
TypesFromInt96PageReader(org.apache.parquet.column.values.ValuesReader realReader, boolean isUtcTimestamp)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TimestampData
readTimestamp()
TimestampData
readTimestamp(int id)
-
Methods inherited from class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
getDictionary, initFromPage, readBoolean, readBoolean, readBytes, readBytes, readDouble, readDouble, readFloat, readFloat, readInteger, readInteger, readLong, readLong, readSmallInt, readSmallInt, readTinyInt, readTinyInt, readValueDictionaryId, skip
-
-
-
-
Method Detail
-
readTimestamp
public TimestampData readTimestamp(int id)
- Specified by:
readTimestamp
in interfaceParquetDataColumnReader
- Overrides:
readTimestamp
in classParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
- Parameters:
id
- in dictionary- Returns:
- the TimestampData from the dictionary by id
-
readTimestamp
public TimestampData readTimestamp()
- Specified by:
readTimestamp
in interfaceParquetDataColumnReader
- Overrides:
readTimestamp
in classParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
- Returns:
- the next TimestampData from the page
-
-