Class NestedPrimitiveColumnReader
- java.lang.Object
-
- org.apache.flink.formats.parquet.vector.reader.NestedPrimitiveColumnReader
-
- All Implemented Interfaces:
ColumnReader<WritableColumnVector>
public class NestedPrimitiveColumnReader extends Object implements ColumnReader<WritableColumnVector>
Reader to read nested primitive column.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
NestedPrimitiveColumnReader.NullIntIterator
Reading zero always.protected static class
NestedPrimitiveColumnReader.RLEIntIterator
Reading int fromRunLengthBitPackingHybridDecoder
.protected static class
NestedPrimitiveColumnReader.ValuesReaderIntIterator
Reading int fromValuesReader
.
-
Constructor Summary
Constructors Constructor Description NestedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean isUtcTimestamp, org.apache.parquet.schema.Type parquetType, LogicalType logicalType)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description LevelDelegation
getLevelDelegation()
WritableColumnVector
readAndNewVector(int readNumber, WritableColumnVector vector)
protected void
readPage()
void
readToVector(int readNumber, WritableColumnVector vector)
-
-
-
Constructor Detail
-
NestedPrimitiveColumnReader
public NestedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean isUtcTimestamp, org.apache.parquet.schema.Type parquetType, LogicalType logicalType) throws IOException
- Throws:
IOException
-
-
Method Detail
-
readToVector
public void readToVector(int readNumber, WritableColumnVector vector) throws IOException
- Specified by:
readToVector
in interfaceColumnReader<WritableColumnVector>
- Parameters:
readNumber
- number to read.vector
- vector to write.- Throws:
IOException
-
readAndNewVector
public WritableColumnVector readAndNewVector(int readNumber, WritableColumnVector vector) throws IOException
- Throws:
IOException
-
getLevelDelegation
public LevelDelegation getLevelDelegation()
-
readPage
protected void readPage()
-
-