public static class TierObjectStore.TierPartitionStateSnapshotMetadata extends Object implements TierObjectStore.ObjectStoreMetadata
Constructor and Description |
---|
TierPartitionStateSnapshotMetadata(TopicIdPartition topicIdPartition,
long lastMaterializedEventTimestamp,
OffsetAndEpoch lastMaterializedEventOffsetAndEpoch,
int tierEpoch) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
OffsetAndEpoch |
lastMaterializedEventOffsetAndEpoch() |
long |
lastMaterializedEventTimestamp() |
Map<String,String> |
objectMetadata(Optional<String> clusterIdOpt,
Optional<Integer> brokerIdOpt)
Converts an ObjectStoreMetadata to a map of metadata that may be useful to place on
objects in object storage, if this functionality is present in the object store
implementation of choice
|
TierObjectStore.OpaqueData |
opaqueData() |
int |
tierEpoch() |
String |
toPath(String keyPrefix,
TierObjectStore.FileType fileType)
Converts the ObjectStoreMetadata to an object store key path, taking into account a
given key prefix and file type
|
TopicIdPartition |
topicIdPartition() |
String |
toString() |
int |
version() |
public TierPartitionStateSnapshotMetadata(TopicIdPartition topicIdPartition, long lastMaterializedEventTimestamp, OffsetAndEpoch lastMaterializedEventOffsetAndEpoch, int tierEpoch)
public TopicIdPartition topicIdPartition()
public long lastMaterializedEventTimestamp()
public OffsetAndEpoch lastMaterializedEventOffsetAndEpoch()
public int tierEpoch()
public int version()
public String toPath(String keyPrefix, TierObjectStore.FileType fileType)
TierObjectStore.ObjectStoreMetadata
toPath
in interface TierObjectStore.ObjectStoreMetadata
keyPrefix
- object key prefixfileType
- object file typepublic Map<String,String> objectMetadata(Optional<String> clusterIdOpt, Optional<Integer> brokerIdOpt)
TierObjectStore.ObjectStoreMetadata
objectMetadata
in interface TierObjectStore.ObjectStoreMetadata
clusterIdOpt
- optional kafka cluster idbrokerIdOpt
- optional kafka broker idpublic TierObjectStore.OpaqueData opaqueData()
opaqueData
in interface TierObjectStore.ObjectStoreMetadata