Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-30293

Create an enumerator for static (batch)

    XMLWordPrintableJSON

Details

    Description

      In FLINK-30207, we have created enumerator for continuous.
      We should have an enumerator for static (batch).
      For example, for the current read-compacted, time traveling may specify the commit time to read snapshots in the future.
      I think these capabilities need to be in the core, but should they be in scan? (It seems that it should not)

      Attachments

        Activity

          People

            TsReaper Caizhi Weng
            lzljs3620320 Jingsong Lee
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: