Stephan Ewen created FLINK-19800: ------------------------------------ Summary: Make FileSourceSplit / FileSourceSplitState interaction extensible. Key: FLINK-19800 URL: https://issues.apache.org/jira/browse/FLINK-19800 Project: Flink Issue Type: Sub-task Components: Connectors / FileSystem Reporter: Stephan Ewen Assignee: Stephan Ewen Fix For: 1.12.0
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. -- This message was sent by Atlassian Jira (v8.3.4#803005)