Package com.linkedin.venice.utils

Class PubSubHelper.MutableDefaultPubSubMessage

java.lang.Object

com.linkedin.venice.utils.PubSubHelper.MutableDefaultPubSubMessage

All Implemented Interfaces:

Measurable, DefaultPubSubMessage, PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Enclosing class:

PubSubHelper

public static class PubSubHelper.MutableDefaultPubSubMessage
extends Object
implements DefaultPubSubMessage

Constructor Summary

Constructors

Constructor	Description
MutableDefaultPubSubMessage()

Method Summary

Modifier and Type	Method	Description
int	getHeapSize()
KafkaKey	getKey()	Retrieves the key associated with this message.
int	getPayloadSize()
PubSubPosition	getPosition()	Retrieves the position of this message within the underlying topic-partition.
long	getPubSubMessageTime()
long	getTimestampAfterProduce()
long	getTimestampBeforeProduce()
PubSubTopicPartition	getTopicPartition()
KafkaMessageEnvelope	getValue()	Retrieves the value payload of this message.
boolean	isEndOfBootstrap()
PubSubHelper.MutableDefaultPubSubMessage	setKey(KafkaKey key)
PubSubHelper.MutableDefaultPubSubMessage	setPosition(PubSubPosition position)
PubSubHelper.MutableDefaultPubSubMessage	setTimestampAfterProduce(long timestampAfterProduce)
PubSubHelper.MutableDefaultPubSubMessage	setTimestampBeforeProduce(long timestampBeforeProduce)
PubSubHelper.MutableDefaultPubSubMessage	setTopicPartition(PubSubTopicPartition topicPartition)
PubSubHelper.MutableDefaultPubSubMessage	setValue(KafkaMessageEnvelope value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.linkedin.venice.pubsub.api.PubSubMessage

getOffset, getPartition, getPubSubMessageHeaders, getReplicationMetadataPayload, getTopic, getTopicName, getWriterSchemaId

Constructor Details

MutableDefaultPubSubMessage

public MutableDefaultPubSubMessage()

Method Details

getKey

public KafkaKey getKey()

Description copied from interface: DefaultPubSubMessage

Retrieves the key associated with this message.

Specified by:

getKey in interface DefaultPubSubMessage

Specified by:

getKey in interface PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Returns:

the KafkaKey representing the message key.

getValue

public KafkaMessageEnvelope getValue()

Description copied from interface: DefaultPubSubMessage

Retrieves the value payload of this message.

Specified by:

getValue in interface DefaultPubSubMessage

Specified by:

getValue in interface PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Returns:

the KafkaMessageEnvelope containing the message data.

getTopicPartition

public PubSubTopicPartition getTopicPartition()

Specified by:

getTopicPartition in interface PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Returns:

the topic-partition this message belongs to

getPosition

public PubSubPosition getPosition()

Description copied from interface: DefaultPubSubMessage

Retrieves the position of this message within the underlying topic-partition.

Specified by:

getPosition in interface DefaultPubSubMessage

Specified by:

getPosition in interface PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Returns:

the PubSubPosition representing the message offset.

getPubSubMessageTime

public long getPubSubMessageTime()

Specified by:

getPubSubMessageTime in interface PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Returns:

the timestamp at which the message was persisted in the pub sub system

getPayloadSize

public int getPayloadSize()

Specified by:

getPayloadSize in interface PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Returns:

the size in bytes of the key + value.

isEndOfBootstrap

public boolean isEndOfBootstrap()

Specified by:

isEndOfBootstrap in interface PubSubMessage<KafkaKey,KafkaMessageEnvelope,PubSubPosition>

Returns:

whether this message marks the end of bootstrap.

setKey

public PubSubHelper.MutableDefaultPubSubMessage setKey(KafkaKey key)

setValue

public PubSubHelper.MutableDefaultPubSubMessage setValue(KafkaMessageEnvelope value)

setTopicPartition

public PubSubHelper.MutableDefaultPubSubMessage setTopicPartition(PubSubTopicPartition topicPartition)

setPosition

public PubSubHelper.MutableDefaultPubSubMessage setPosition(PubSubPosition position)

setTimestampBeforeProduce

public PubSubHelper.MutableDefaultPubSubMessage setTimestampBeforeProduce(long timestampBeforeProduce)

setTimestampAfterProduce

public PubSubHelper.MutableDefaultPubSubMessage setTimestampAfterProduce(long timestampAfterProduce)

getTimestampBeforeProduce

public long getTimestampBeforeProduce()

getTimestampAfterProduce

public long getTimestampAfterProduce()

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable