public static class TierObjectStore.ObjectMetadata extends java.lang.Object implements TierObjectStore.ObjectStoreMetadata
Constructor and Description |
---|
ObjectMetadata(TierObjectMetadata metadata) |
ObjectMetadata(TopicIdPartition topicIdPartition,
java.util.UUID objectId,
int tierEpoch,
long baseOffset,
boolean hasAbortedTxns,
boolean hasProducerState,
boolean hasEpochState) |
Modifier and Type | Method and Description |
---|---|
long |
baseOffset() |
boolean |
equals(java.lang.Object o) |
boolean |
hasAbortedTxns() |
boolean |
hasEpochState() |
int |
hashCode() |
boolean |
hasProducerState() |
java.util.UUID |
objectId() |
java.lang.String |
objectIdAsBase64() |
java.util.Map<java.lang.String,java.lang.String> |
objectMetadata(java.util.Optional<java.lang.String> clusterIdOpt,
java.util.Optional<java.lang.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
|
int |
tierEpoch() |
java.lang.String |
toPath(java.lang.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() |
java.lang.String |
toString() |
public ObjectMetadata(TopicIdPartition topicIdPartition, java.util.UUID objectId, int tierEpoch, long baseOffset, boolean hasAbortedTxns, boolean hasProducerState, boolean hasEpochState)
public ObjectMetadata(TierObjectMetadata metadata)
public TopicIdPartition topicIdPartition()
public java.util.UUID objectId()
public java.lang.String objectIdAsBase64()
public int tierEpoch()
public long baseOffset()
public boolean hasAbortedTxns()
public boolean hasProducerState()
public boolean hasEpochState()
public java.util.Map<java.lang.String,java.lang.String> objectMetadata(java.util.Optional<java.lang.String> clusterIdOpt, java.util.Optional<java.lang.Integer> brokerIdOpt)
TierObjectStore.ObjectStoreMetadata
objectMetadata
in interface TierObjectStore.ObjectStoreMetadata
clusterIdOpt
- optional kafka cluster idbrokerIdOpt
- optional kafka broker idpublic java.lang.String toPath(java.lang.String keyPrefix, TierObjectStore.FileType fileType)
TierObjectStore.ObjectStoreMetadata
toPath
in interface TierObjectStore.ObjectStoreMetadata
keyPrefix
- object key prefixfileType
- object file typepublic boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object