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

Class MapColumnReader

java.lang.Object

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

All Implemented Interfaces:

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

public class MapColumnReader
extends Object
implements ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>

Map ColumnReader.

Constructor Summary

Constructors

Constructor	Description
MapColumnReader(ArrayColumnReader keyReader, ArrayColumnReader valueReader)

Method Summary

Modifier and Type	Method	Description
void	readBatch(int total, org.apache.flink.table.data.columnar.vector.ColumnVector column)
void	readToVector(int readNumber, org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapColumnReader

public MapColumnReader(ArrayColumnReader keyReader,
                       ArrayColumnReader valueReader)

Method Detail

readBatch

public void readBatch(int total,
                      org.apache.flink.table.data.columnar.vector.ColumnVector column)
               throws IOException

Throws:

IOException

readToVector

public void readToVector(int readNumber,
                         org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector)
                  throws IOException

Specified by:

readToVector in interface ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>

Parameters:

readNumber - number to read.

vector - vector to write.

Throws:

IOException