@InterfaceStability.Evolving public class RemoteLogSegmentMetadataUpdate extends RemoteLogMetadata
RemoteLogMetadataManager.updateRemoteLogSegmentMetadata(RemoteLogSegmentMetadataUpdate)
.
This also includes the timestamp of this event.Constructor and Description |
---|
RemoteLogSegmentMetadataUpdate(RemoteLogSegmentId remoteLogSegmentId,
long eventTimestampMs,
RemoteLogSegmentState state,
int brokerId) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
RemoteLogSegmentId |
remoteLogSegmentId() |
RemoteLogSegmentState |
state()
It represents the state of the remote log segment.
|
org.apache.kafka.common.TopicIdPartition |
topicIdPartition() |
String |
toString() |
brokerId, eventTimestampMs
public RemoteLogSegmentMetadataUpdate(RemoteLogSegmentId remoteLogSegmentId, long eventTimestampMs, RemoteLogSegmentState state, int brokerId)
remoteLogSegmentId
- Universally unique remote log segment id.eventTimestampMs
- Epoch time in milli seconds at which the remote log segment is copied to the remote tier storage.state
- State of the remote log segment.brokerId
- Broker id from which this event is generated.public RemoteLogSegmentId remoteLogSegmentId()
public RemoteLogSegmentState state()
RemoteLogSegmentState
.public org.apache.kafka.common.TopicIdPartition topicIdPartition()
topicIdPartition
in class RemoteLogMetadata