Package org.apache.flink.connector.file.src.util

Interface Summary

Interface	Description
Pool.Recycler<T>	A Recycler puts objects into the pool that the recycler is associated with.
RecordMapperWrapperRecordIterator.RecordMapper<I,O>	Record mapper definition.

Class Summary

Class	Description
ArrayResultIterator<E>	A simple BulkFormat.RecordIterator that returns the elements of an array, one after the other.
CheckpointedPosition	The position of a reader, to be stored in a checkpoint.
IteratorResultIterator<E>	A simple BulkFormat.RecordIterator that returns the elements of an iterator, augmented with position information.
MutableRecordAndPosition<E>	A mutable version of the RecordAndPosition.
Pool<T>	A pool to cache and recycle heavyweight objects, to reduce object allocation.
RecordAndPosition<E>	A record, together with the reader position to be stored in the checkpoint.
RecordMapperWrapperRecordIterator<I,O>	Implementation of BulkFormat.RecordIterator that wraps another iterator and performs the mapping of the records.
RecyclableIterator<E>	Utility base class for iterators that accept a recycler.
SingletonResultIterator<E>	A simple BulkFormat.RecordIterator that returns a single value.
Utils	Miscellaneous utilities for the file source.