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
org.apache.flink.connectors.hive.read
org.apache.flink.orc

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 and 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 and 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 and Description
FileSourceSplit(String id, Path filePath, long offset, long length, 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 and Description
default CheckpointedPosition	StreamFormat.Reader.getCheckpointedPosition() Optionally returns the current position of the reader.
default CheckpointedPosition	FileRecordFormat.Reader.getCheckpointedPosition() Optionally returns the current position of the reader.

Uses of CheckpointedPosition in org.apache.flink.connectors.hive.read

Methods in org.apache.flink.connectors.hive.read with parameters of type CheckpointedPosition

Modifier and Type	Method and Description
FileSourceSplit	HiveSourceSplit.updateWithCheckpointedPosition(CheckpointedPosition position)

Constructors in org.apache.flink.connectors.hive.read with parameters of type CheckpointedPosition

Constructor and Description
HiveSourceSplit(org.apache.hadoop.mapred.FileSplit fileSplit, HiveTablePartition hiveTablePartition, CheckpointedPosition readerPosition)
HiveSourceSplit(String id, Path filePath, long offset, long length, String[] hostnames, CheckpointedPosition readerPosition, HiveTablePartition hiveTablePartition)

Uses of CheckpointedPosition in org.apache.flink.orc

Methods in org.apache.flink.orc with parameters of type CheckpointedPosition

Modifier and Type	Method and Description
void	AbstractOrcFileInputFormat.OrcVectorizedReader.seek(CheckpointedPosition position) The argument of RecordReader.seekToRow(long) must come from RecordReader.getRowNumber().