public class ReaderConsumeProgressEvent extends Object implements org.apache.flink.api.connector.source.SourceEvent
FileStoreSourceReader
to ContinuousFileSplitEnumerator
to
describe the current consumption progress.Constructor and Description |
---|
ReaderConsumeProgressEvent(long lastConsumeSnapshotId) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.