Modifier and Type | Field and Description |
---|---|
static String |
EARLIEST |
static String |
LATEST |
Constructor and Description |
---|
SnapshotManager(org.apache.flink.core.fs.Path tablePath) |
Modifier and Type | Method and Description |
---|---|
void |
commitEarliestHint(long snapshotId) |
void |
commitLatestHint(long snapshotId) |
Long |
earlierOrEqualTimeMills(long timestampMills)
Returns a snapshot earlier than or equals to the timestamp mills.
|
Long |
earlierThanTimeMills(long timestampMills)
Returns a snapshot earlier than the timestamp mills.
|
Long |
earliestSnapshotId() |
Long |
latestCompactedSnapshotId() |
Long |
latestSnapshotId() |
Optional<Snapshot> |
latestSnapshotOfUser(String user) |
Long |
readHint(String fileName) |
Snapshot |
snapshot(long snapshotId) |
long |
snapshotCount() |
org.apache.flink.core.fs.Path |
snapshotDirectory() |
boolean |
snapshotExists(long snapshotId) |
org.apache.flink.core.fs.Path |
snapshotPath(long snapshotId) |
Iterator<Snapshot> |
snapshots() |
public static final String EARLIEST
public static final String LATEST
public org.apache.flink.core.fs.Path snapshotDirectory()
public org.apache.flink.core.fs.Path snapshotPath(long snapshotId)
public Snapshot snapshot(long snapshotId)
public boolean snapshotExists(long snapshotId)
@Nullable public Long earlierThanTimeMills(long timestampMills)
@Nullable public Long earlierOrEqualTimeMills(long timestampMills)
public long snapshotCount() throws IOException
IOException
public Iterator<Snapshot> snapshots() throws IOException
IOException
public void commitLatestHint(long snapshotId) throws IOException
IOException
public void commitEarliestHint(long snapshotId) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.