Package com.linkedin.davinci.consumer

Class ImmutableChangeCapturePubSubMessage<K,V>

java.lang.Object

com.linkedin.davinci.consumer.ImmutableChangeCapturePubSubMessage<K,V>

All Implemented Interfaces:

Measurable, PubSubMessage<K,V,VeniceChangeCoordinate>

public class ImmutableChangeCapturePubSubMessage<K,V>
extends java.lang.Object
implements PubSubMessage<K,V,VeniceChangeCoordinate>

Constructor Summary

Constructors

Constructor	Description
ImmutableChangeCapturePubSubMessage(K key, V value, PubSubTopicPartition topicPartition, long offset, long timestamp, int payloadSize, boolean isEndOfBootstrap)

Method Summary

Modifier and Type	Method	Description
int	getHeapSize()
K	getKey()
VeniceChangeCoordinate	getOffset()
int	getPayloadSize()
long	getPubSubMessageTime()
PubSubTopicPartition	getTopicPartition()
V	getValue()
boolean	isEndOfBootstrap()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

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

getPartition, getPubSubMessageHeaders, getTopic, getTopicName

Constructor Detail

ImmutableChangeCapturePubSubMessage

public ImmutableChangeCapturePubSubMessage(K key,
                                           V value,
                                           PubSubTopicPartition topicPartition,
                                           long offset,
                                           long timestamp,
                                           int payloadSize,
                                           boolean isEndOfBootstrap)

Method Detail

getKey

public K getKey()

Specified by:

getKey in interface PubSubMessage<K,V,VeniceChangeCoordinate>

Returns:

the key part of this message

getValue

public V getValue()

Specified by:

getValue in interface PubSubMessage<K,V,VeniceChangeCoordinate>

Returns:

the value part of this message

getTopicPartition

public PubSubTopicPartition getTopicPartition()

Specified by:

getTopicPartition in interface PubSubMessage<K,V,VeniceChangeCoordinate>

Returns:

the topic-partition this message belongs to

getOffset

public VeniceChangeCoordinate getOffset()

Specified by:

getOffset in interface PubSubMessage<K,V,VeniceChangeCoordinate>

Returns:

the offset of this message in the underlying topic-partition

getPubSubMessageTime

public long getPubSubMessageTime()

Specified by:

getPubSubMessageTime in interface PubSubMessage<K,V,VeniceChangeCoordinate>

Returns:

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

getPayloadSize

public int getPayloadSize()

Specified by:

getPayloadSize in interface PubSubMessage<K,V,VeniceChangeCoordinate>

Returns:

the size in bytes of the key + value.

isEndOfBootstrap

public boolean isEndOfBootstrap()

Specified by:

isEndOfBootstrap in interface PubSubMessage<K,V,VeniceChangeCoordinate>

Returns:

whether this message marks the end of bootstrap.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable