Class RowColumnReader
- java.lang.Object
-
- org.apache.flink.formats.parquet.vector.reader.RowColumnReader
-
- All Implemented Interfaces:
ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>
public class RowColumnReader extends Object implements ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>
RowColumnReader.
-
-
Constructor Summary
Constructors Constructor Description RowColumnReader(List<ColumnReader> fieldReaders)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidreadToVector(int readNumber, org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector)
-
-
-
Constructor Detail
-
RowColumnReader
public RowColumnReader(List<ColumnReader> fieldReaders)
-
-
Method Detail
-
readToVector
public void readToVector(int readNumber, org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector) throws IOException- Specified by:
readToVectorin interfaceColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>- Parameters:
readNumber- number to read.vector- vector to write.- Throws:
IOException
-
-