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

Interface ColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>

All Known Implementing Classes:

AbstractColumnReader, ArrayColumnReader, BaseVectorizedColumnReader, BooleanColumnReader, ByteColumnReader, BytesColumnReader, DoubleColumnReader, FixedLenBytesColumnReader, FloatColumnReader, IntColumnReader, LongColumnReader, MapColumnReader, RowColumnReader, ShortColumnReader, TimestampColumnReader

public interface ColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.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