Uses of Class
org.apache.flink.connector.file.src.util.CheckpointedPosition

Packages that use CheckpointedPosition

Package	Description
org.apache.flink.connector.file.src
org.apache.flink.connector.file.src.reader

Uses of CheckpointedPosition in org.apache.flink.connector.file.src

Methods in org.apache.flink.connector.file.src that return types with arguments of type CheckpointedPosition

Modifier and Type	Method	Description
Optional<CheckpointedPosition>	FileSourceSplit.getReaderPosition()	Gets the (checkpointed) position of the reader, if set.

Methods in org.apache.flink.connector.file.src with parameters of type CheckpointedPosition

Modifier and Type	Method	Description
void	FileSourceSplitState.setPosition(CheckpointedPosition position)
FileSourceSplit	FileSourceSplit.updateWithCheckpointedPosition(CheckpointedPosition position)	Creates a copy of this split where the checkpointed position is replaced by the given new position.

Constructors in org.apache.flink.connector.file.src with parameters of type CheckpointedPosition

Constructor	Description
FileSourceSplit(String id, org.apache.flink.core.fs.Path filePath, long offset, long length, long fileModificationTime, long fileSize, String[] hostnames, CheckpointedPosition readerPosition)	Constructs a split with host information.

Uses of CheckpointedPosition in org.apache.flink.connector.file.src.reader

Methods in org.apache.flink.connector.file.src.reader that return CheckpointedPosition

Modifier and Type	Method	Description
default CheckpointedPosition	StreamFormat.Reader.getCheckpointedPosition()	Optionally returns the current position of the reader.