Modifier and Type | Method and Description |
---|---|
Snapshot |
StaticFileStoreSplitEnumerator.snapshot() |
Constructor and Description |
---|
StaticFileStoreSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
Snapshot snapshot,
Collection<FileStoreSourceSplit> splits) |
Modifier and Type | Method and Description |
---|---|
static Snapshot |
Snapshot.fromJson(String json) |
static Snapshot |
Snapshot.fromPath(org.apache.flink.core.fs.Path path) |
Modifier and Type | Method and Description |
---|---|
Snapshot |
SnapshotManager.snapshot(long snapshotId) |
Modifier and Type | Method and Description |
---|---|
Optional<Snapshot> |
SnapshotManager.latestSnapshotOfUser(String user) |
Iterator<Snapshot> |
SnapshotManager.snapshots() |
Modifier and Type | Method and Description |
---|---|
boolean |
DeltaFollowUpScanner.shouldScanSnapshot(Snapshot snapshot) |
boolean |
FollowUpScanner.shouldScanSnapshot(Snapshot snapshot) |
boolean |
InputChangelogFollowUpScanner.shouldScanSnapshot(Snapshot snapshot) |
boolean |
CompactionChangelogFollowUpScanner.shouldScanSnapshot(Snapshot snapshot) |
boolean |
ContinuousCompactorFollowUpScanner.shouldScanSnapshot(Snapshot snapshot) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.