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 Object
implements PubSubMessage<K,V,VeniceChangeCoordinate>

Constructor Summary

Constructors

Constructor	Description
ImmutableChangeCapturePubSubMessage(K key, V value, PubSubTopicPartition topicPartition, PubSubPosition pubSubPosition, long timestamp, int payloadSize, boolean isEndOfBootstrap, long consumerSequenceId)
ImmutableChangeCapturePubSubMessage(K key, V value, PubSubTopicPartition topicPartition, PubSubPosition pubSubPosition, long timestamp, int payloadSize, boolean isEndOfBootstrap, long consumerSequenceId, int writerSchemaId, ByteBuffer replicationMetadataPayload)

Method Summary

Modifier and Type	Method	Description
int	getHeapSize()
K	getKey()
int	getPayloadSize()
VeniceChangeCoordinate	getPosition()
long	getPubSubMessageTime()
ByteBuffer	getReplicationMetadataPayload()
PubSubTopicPartition	getTopicPartition()
V	getValue()
int	getWriterSchemaId()
boolean	isEndOfBootstrap()
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

getOffset, getPartition, getPubSubMessageHeaders, getTopic, getTopicName

Constructor Details

ImmutableChangeCapturePubSubMessage

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

ImmutableChangeCapturePubSubMessage

public ImmutableChangeCapturePubSubMessage(K key,
 V value,
 PubSubTopicPartition topicPartition,
 PubSubPosition pubSubPosition,
 long timestamp,
 int payloadSize,
 boolean isEndOfBootstrap,
 long consumerSequenceId,
 int writerSchemaId,
 ByteBuffer replicationMetadataPayload)

Method Details

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

getPosition

public VeniceChangeCoordinate getPosition()

Specified by:

getPosition in interface PubSubMessage<K,V,VeniceChangeCoordinate>

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.

getWriterSchemaId

public int getWriterSchemaId()

getReplicationMetadataPayload

public ByteBuffer getReplicationMetadataPayload()

toString

public String toString()

Overrides:

toString in class Object

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable