Package org.apache.flink.formats.parquet.vector.reader

Interface ColumnReader<VECTOR extends WritableColumnVector>

All Known Implementing Classes:

AbstractColumnReader, BooleanColumnReader, ByteColumnReader, BytesColumnReader, DoubleColumnReader, FixedLenBytesColumnReader, FloatColumnReader, IntColumnReader, LongColumnReader, NestedColumnReader, NestedPrimitiveColumnReader, ShortColumnReader, TimestampColumnReader

public interface ColumnReader<VECTOR extends WritableColumnVector>

Read a batch of records for a column to WritableColumnVector from parquet data file.

Method Summary

Modifier and Type	Method	Description
void	readToVector(int readNumber, VECTOR vector)

Method Detail

readToVector

void readToVector(int readNumber,
                  VECTOR vector)
           throws IOException

Parameters:

readNumber - number to read.

vector - vector to write.

Throws:

IOException