Package | Description |
---|---|
org.apache.flink.table.store.table.source.snapshot |
Constructor and Description |
---|
ContinuousDataFileSnapshotEnumerator(org.apache.flink.core.fs.Path tablePath,
DataTableScan scan,
StartingScanner startingScanner,
FollowUpScanner followUpScanner,
Long nextSnapshotId) |
StaticDataFileSnapshotEnumerator(org.apache.flink.core.fs.Path tablePath,
DataTableScan scan,
StartingScanner startingScanner) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.