PubSubMessage (venice API)

All Superinterfaces:: Measurable

All Known Implementing Classes:: ImmutableChangeCapturePubSubMessage, ImmutablePubSubMessage, PubSubHelper.MutablePubSubMessage

public interface PubSubMessage<K,V,OFFSET> extends Measurable

Method Summary

Modifier and Type

Method

Description

K

getKey()

OFFSET

getOffset()

default int

getPartition()

int

getPayloadSize()

default PubSubMessageHeaders

getPubSubMessageHeaders()

long

getPubSubMessageTime()

default PubSubTopic

getTopic()

default String

getTopicName()

PubSubTopicPartition

getTopicPartition()

V

getValue()

boolean

isEndOfBootstrap()

Methods inherited from interface com.linkedin.venice.memory.Measurable
getHeapSize

Method Details
- getKey
  
  K getKey()
  
  Returns:
  
  the key part of this message
- getValue
  
  V getValue()
  
  Returns:
  
  the value part of this message
- getTopicPartition
  
  PubSubTopicPartition getTopicPartition()
  
  Returns:
  
  the topic-partition this message belongs to
- getOffset
  
  OFFSET getOffset()
  
  Returns:
  
  the offset of this message in the underlying topic-partition
- getPubSubMessageTime
  
  long getPubSubMessageTime()
  
  Returns:
  
  the timestamp at which the message was persisted in the pub sub system
- getPayloadSize
  
  int getPayloadSize()
  
  Returns:
  
  the size in bytes of the key + value.
- getTopicName
  
  default String getTopicName()
- getTopic
  
  default PubSubTopic getTopic()
- getPartition
  
  default int getPartition()
- isEndOfBootstrap
  
  boolean isEndOfBootstrap()
  
  Returns:
  
  whether this message marks the end of bootstrap.
- getPubSubMessageHeaders
  
  default PubSubMessageHeaders getPubSubMessageHeaders()