[jira] [Created] (FLINK-30207) Move split initialization and discovery logic fully into SnapshotEnumerator in Table Store

["Caizhi Weng (Jira)" <ji...@apache.org>]

Caizhi Weng created FLINK-30207:
-----------------------------------

             Summary: Move split initialization and discovery logic fully into SnapshotEnumerator in Table Store
                 Key: FLINK-30207
                 URL: https://issues.apache.org/jira/browse/FLINK-30207
             Project: Flink
          Issue Type: Sub-task
          Components: Table Store
    Affects Versions: table-store-0.3.0
            Reporter: Caizhi Weng
            Assignee: Caizhi Weng
             Fix For: table-store-0.3.0


It is possible that the separated compact job is started long after the write jobs. so compact job sources need a special split initialization logic: we will find the latest COMPACT snapshot, and start compacting right after this snapshot.

However, split initialization logic are currently coded into {{FileStoreSource}}. We should extract these logic into {{SnapshotEnumerator}} so that we can create our special {{SnapshotEnumerator}} for compact sources.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)