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 RecordIterator reading interface from convertAndGetIterator(long).

Field Summary

Fields

Modifier and Type	Field and Description
protected VectorizedColumnBatch	columnarBatch

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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