[FLINK-19800] Make FileSourceSplit / FileSourceSplitState interaction extensible.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Connectors / FileSystem
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 25/Oct/20 14:08
• Updated: 05/Nov/20 15:01
• Resolved: 05/Nov/20 15:01

Description

We should add a method FileSourceSplit.updateWithCheckpointedPosition(CheckpointedPosition) that creates a new FileSourceSplit of the same type with an updated position.

Subclasses can override that method. The FileSourceSplitState uses that method to create the splits that are stored in the checkpoint.