public class Snapshot extends Object
Versioned change list:
Unversioned change list:
Modifier and Type | Class and Description |
---|---|
static class |
Snapshot.CommitKind
Type of changes in this snapshot.
|
Modifier and Type | Field and Description |
---|---|
static long |
FIRST_SNAPSHOT_ID |
Constructor and Description |
---|
Snapshot(Integer version,
long id,
long schemaId,
String baseManifestList,
String deltaManifestList,
String changelogManifestList,
String commitUser,
long commitIdentifier,
Snapshot.CommitKind commitKind,
long timeMillis,
Map<Integer,Long> logOffsets) |
Snapshot(long id,
long schemaId,
String baseManifestList,
String deltaManifestList,
String changelogManifestList,
String commitUser,
long commitIdentifier,
Snapshot.CommitKind commitKind,
long timeMillis,
Map<Integer,Long> logOffsets) |
Modifier and Type | Method and Description |
---|---|
String |
baseManifestList() |
String |
changelogManifestList() |
long |
commitIdentifier() |
Snapshot.CommitKind |
commitKind() |
String |
commitUser() |
String |
deltaManifestList() |
static Snapshot |
fromJson(String json) |
static Snapshot |
fromPath(org.apache.flink.core.fs.Path path) |
Map<Integer,Long> |
getLogOffsets() |
long |
id() |
List<ManifestFileMeta> |
readAllDataManifests(ManifestList manifestList) |
long |
schemaId() |
long |
timeMillis() |
String |
toJson() |
int |
version() |
public static final long FIRST_SNAPSHOT_ID
public Snapshot(long id, long schemaId, String baseManifestList, String deltaManifestList, @Nullable String changelogManifestList, String commitUser, long commitIdentifier, Snapshot.CommitKind commitKind, long timeMillis, Map<Integer,Long> logOffsets)
public int version()
public long id()
public long schemaId()
public String baseManifestList()
public String deltaManifestList()
public String commitUser()
public long commitIdentifier()
public Snapshot.CommitKind commitKind()
public long timeMillis()
public String toJson()
public List<ManifestFileMeta> readAllDataManifests(ManifestList manifestList)
public static Snapshot fromPath(org.apache.flink.core.fs.Path path)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.