public static class TierObjectStore.ObjectMetadata extends Object implements TierObjectStore.ObjectStoreMetadata
Constructor and Description |
---|
ObjectMetadata(TopicIdPartition topicIdPartition,
SegmentState metadata) |
ObjectMetadata(TopicIdPartition topicIdPartition,
UUID objectId,
int tierEpoch,
long baseOffset,
boolean hasAbortedTxns,
boolean hasProducerState,
boolean hasEpochState,
TierObjectStore.OpaqueData opaqueData) |
Modifier and Type | Method and Description |
---|---|
long |
baseOffset() |
boolean |
equals(Object o) |
boolean |
hasAbortedTxns() |
boolean |
hasEpochState() |
int |
hashCode() |
boolean |
hasProducerState() |
UUID |
objectId() |
String |
objectIdAsBase64() |
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() |
public ObjectMetadata(TopicIdPartition topicIdPartition, UUID objectId, int tierEpoch, long baseOffset, boolean hasAbortedTxns, boolean hasProducerState, boolean hasEpochState, TierObjectStore.OpaqueData opaqueData)
public ObjectMetadata(TopicIdPartition topicIdPartition, SegmentState metadata)
public TopicIdPartition topicIdPartition()
public UUID objectId()
public String objectIdAsBase64()
public int tierEpoch()
public long baseOffset()
public boolean hasAbortedTxns()
public boolean hasProducerState()
public boolean hasEpochState()
public 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
public String toPath(String keyPrefix, TierObjectStore.FileType fileType)
TierObjectStore.ObjectStoreMetadata
toPath
in interface TierObjectStore.ObjectStoreMetadata
keyPrefix
- object key prefixfileType
- object file type