Package com.linkedin.venice.writer

Class LeaderMetadataWrapper

java.lang.Object

com.linkedin.venice.writer.LeaderMetadataWrapper

public class LeaderMetadataWrapper
extends Object

This is a simple container class to hold Leader metadata related fields together to be passed on to the Put and Delete api in VeniceWriter Caller should construct an instance of this object by properly filling up all the fields of this object.

Constructor Summary

Constructors

Constructor	Description
LeaderMetadataWrapper(long upstreamOffset, int upstreamKafkaClusterId, long termId, ByteBuffer upstreamPubSubPosition)
LeaderMetadataWrapper(long upstreamOffset, int upstreamKafkaClusterId, long termId, ByteBuffer upstreamPubSubPosition, Map<String,Set<Integer>> viewPartitionMap)

Method Summary

Modifier and Type	Method	Description
long	getTermId()
int	getUpstreamKafkaClusterId()
long	getUpstreamOffset()
ByteBuffer	getUpstreamPubSubPosition()
Map<String,Set<Integer>>	getViewPartitionMap()

Methods inherited from class java.lang.Object

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

Constructor Details

LeaderMetadataWrapper

public LeaderMetadataWrapper(long upstreamOffset,
 int upstreamKafkaClusterId,
 long termId,
 ByteBuffer upstreamPubSubPosition)

LeaderMetadataWrapper

public LeaderMetadataWrapper(long upstreamOffset,
 int upstreamKafkaClusterId,
 long termId,
 ByteBuffer upstreamPubSubPosition,
 Map<String,Set<Integer>> viewPartitionMap)

Method Details

getUpstreamOffset

public long getUpstreamOffset()

getUpstreamKafkaClusterId

public int getUpstreamKafkaClusterId()

getViewPartitionMap

public Map<String,Set<Integer>> getViewPartitionMap()

getUpstreamPubSubPosition

public ByteBuffer getUpstreamPubSubPosition()

getTermId

public long getTermId()