Uses of Package
org.apache.flink.connector.file.src.util
-
Classes in org.apache.flink.connector.file.src.util used by org.apache.flink.connector.file.src Class Description CheckpointedPosition The position of a reader, to be stored in a checkpoint. -
Classes in org.apache.flink.connector.file.src.util used by org.apache.flink.connector.file.src.impl Class Description RecordAndPosition A record, together with the reader position to be stored in the checkpoint. -
Classes in org.apache.flink.connector.file.src.util used by org.apache.flink.connector.file.src.reader Class Description CheckpointedPosition The position of a reader, to be stored in a checkpoint.RecordAndPosition A record, together with the reader position to be stored in the checkpoint. -
Classes in org.apache.flink.connector.file.src.util used by org.apache.flink.connector.file.src.util Class Description Pool.Recycler A Recycler puts objects into the pool that the recycler is associated with.RecordAndPosition A record, together with the reader position to be stored in the checkpoint.RecordMapperWrapperRecordIterator.RecordMapper Record mapper definition.RecyclableIterator Utility base class for iterators that accept a recycler. -
Classes in org.apache.flink.connector.file.src.util used by org.apache.flink.connector.file.table Class Description RecordAndPosition A record, together with the reader position to be stored in the checkpoint.RecyclableIterator Utility base class for iterators that accept a recycler.