org.apache.paimon.tag

Class Tag

java.lang.Object

org.apache.paimon.Snapshot

org.apache.paimon.tag.Tag

public class Tag
extends Snapshot

Snapshot with tagCreateTime and tagTimeRetained.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.Snapshot

Snapshot.CommitKind

Field Summary

Fields inherited from class org.apache.paimon.Snapshot

baseManifestList, changelogManifestList, changelogRecordCount, commitIdentifier, commitKind, commitUser, CURRENT_VERSION, deltaManifestList, deltaRecordCount, FIELD_BASE_MANIFEST_LIST, FIELD_CHANGELOG_MANIFEST_LIST, FIELD_CHANGELOG_RECORD_COUNT, FIELD_COMMIT_IDENTIFIER, FIELD_COMMIT_KIND, FIELD_COMMIT_USER, FIELD_DELTA_MANIFEST_LIST, FIELD_DELTA_RECORD_COUNT, FIELD_ID, FIELD_INDEX_MANIFEST, FIELD_LOG_OFFSETS, FIELD_SCHEMA_ID, FIELD_STATISTICS, FIELD_TIME_MILLIS, FIELD_TOTAL_RECORD_COUNT, FIELD_VERSION, FIELD_WATERMARK, FIRST_SNAPSHOT_ID, id, indexManifest, logOffsets, schemaId, statistics, TABLE_STORE_02_VERSION, timeMillis, totalRecordCount, version, watermark

Constructor Summary

Constructors

Constructor and Description

Tag(Integer version, long id, long schemaId, String baseManifestList, String deltaManifestList, String changelogManifestList, String indexManifest, String commitUser, long commitIdentifier, Snapshot.CommitKind commitKind, long timeMillis, Map<Integer,Long> logOffsets, Long totalRecordCount, Long deltaRecordCount, Long changelogRecordCount, Long watermark, String statistics, java.time.LocalDateTime tagCreateTime, java.time.Duration tagTimeRetained)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static Tag	fromJson(String json)
static Tag	fromPath(FileIO fileIO, Path path)
static Tag	fromSnapshotAndTagTtl(Snapshot snapshot, java.time.Duration tagTimeRetained, java.time.LocalDateTime tagCreateTime)
java.time.LocalDateTime	getTagCreateTime()
java.time.Duration	getTagTimeRetained()
int	hashCode()
static Tag	safelyFromPath(FileIO fileIO, Path path)
String	toJson()
Snapshot	trimToSnapshot()

Methods inherited from class org.apache.paimon.Snapshot

baseManifestList, changelogManifestList, changelogRecordCount, commitIdentifier, commitKind, commitUser, deltaManifestList, deltaRecordCount, id, indexManifest, logOffsets, schemaId, statistics, timeMillis, totalRecordCount, version, watermark

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Tag

public Tag(@Nullable
           Integer version,
           long id,
           long schemaId,
           String baseManifestList,
           String deltaManifestList,
           @Nullable
           String changelogManifestList,
           @Nullable
           String indexManifest,
           String commitUser,
           long commitIdentifier,
           Snapshot.CommitKind commitKind,
           long timeMillis,
           Map<Integer,Long> logOffsets,
           @Nullable
           Long totalRecordCount,
           @Nullable
           Long deltaRecordCount,
           @Nullable
           Long changelogRecordCount,
           @Nullable
           Long watermark,
           @Nullable
           String statistics,
           @Nullable
           java.time.LocalDateTime tagCreateTime,
           @Nullable
           java.time.Duration tagTimeRetained)

Method Detail

getTagCreateTime

@Nullable
public java.time.LocalDateTime getTagCreateTime()

getTagTimeRetained

@Nullable
public java.time.Duration getTagTimeRetained()

toJson

public String toJson()

Overrides:

toJson in class Snapshot

fromJson

public static Tag fromJson(String json)

fromPath

public static Tag fromPath(FileIO fileIO,
                           Path path)

safelyFromPath

@Nullable
public static Tag safelyFromPath(FileIO fileIO,
                                           Path path)
                                    throws IOException

Throws:

IOException

fromSnapshotAndTagTtl

public static Tag fromSnapshotAndTagTtl(Snapshot snapshot,
                                        java.time.Duration tagTimeRetained,
                                        java.time.LocalDateTime tagCreateTime)

trimToSnapshot

public Snapshot trimToSnapshot()

hashCode

public int hashCode()

Overrides:

hashCode in class Snapshot

equals

public boolean equals(Object o)

Overrides:

equals in class Snapshot