Package org.apache.flink.formats.parquet

Class ParquetVectorizedInputFormat.ParquetReaderBatch<T>

java.lang.Object

org.apache.flink.formats.parquet.ParquetVectorizedInputFormat.ParquetReaderBatch<T>

Enclosing class:

ParquetVectorizedInputFormat<T,SplitT extends FileSourceSplit>

protected abstract static class ParquetVectorizedInputFormat.ParquetReaderBatch<T>
extends Object

Reader batch that provides writing and reading capabilities. Provides BulkFormat.RecordIterator reading interface from convertAndGetIterator(long).

Field Summary

Fields

Modifier and Type	Field	Description
protected VectorizedColumnBatch	columnarBatch

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ParquetReaderBatch(WritableColumnVector[] writableVectors, VectorizedColumnBatch columnarBatch, Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>> recycler)

Method Summary

Modifier and Type	Method	Description
abstract BulkFormat.RecordIterator<T>	convertAndGetIterator(long rowsReturned)	Provides reading iterator after the records are written to the columnarBatch.
void	recycle()

Methods inherited from class java.lang.Object

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

Field Detail

columnarBatch

protected final VectorizedColumnBatch columnarBatch

Constructor Detail

ParquetReaderBatch

protected ParquetReaderBatch(WritableColumnVector[] writableVectors,
                             VectorizedColumnBatch columnarBatch,
                             Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>> recycler)

Method Detail

recycle

public void recycle()

convertAndGetIterator

public abstract BulkFormat.RecordIterator<T> convertAndGetIterator(long rowsReturned)
                                                            throws IOException

Provides reading iterator after the records are written to the columnarBatch.

Parameters:

rowsReturned - The number of rows that have been returned before this batch.

Throws:

IOException