Package com.linkedin.davinci.consumer

Class VeniceChangeCoordinate

java.lang.Object

com.linkedin.davinci.consumer.VeniceChangeCoordinate

All Implemented Interfaces:

Externalizable, Serializable

public class VeniceChangeCoordinate
extends Object
implements Externalizable

See Also:

• Serialized Form

Constructor Summary

Constructors

Modifier	Constructor	Description
	VeniceChangeCoordinate()
protected	VeniceChangeCoordinate(String topic, PubSubPosition pubSubPosition, Integer partition)

Method Summary

Modifier and Type	Method	Description
int	comparePosition(VeniceChangeCoordinate other)
static String	convertVeniceChangeCoordinateToStringAndEncode(VeniceChangeCoordinate veniceChangeCoordinate)
static VeniceChangeCoordinate	decodeStringAndConvertToVeniceChangeCoordinate(String offsetString)
Integer	getPartition()
protected PubSubPosition	getPosition()
String	getStoreName()
protected String	getTopic()
void	readExternal(ObjectInput in)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceChangeCoordinate

public VeniceChangeCoordinate()

VeniceChangeCoordinate

protected VeniceChangeCoordinate(String topic,
 PubSubPosition pubSubPosition,
 Integer partition)

Method Details

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

getPartition

public Integer getPartition()

getStoreName

public String getStoreName()

comparePosition

public int comparePosition(VeniceChangeCoordinate other)

Parameters:

other - the other position to compare to

Returns:

returns 0 if the positions are equal, -1 if this position is less than the other position, and 1 if this position is greater than the other position

getTopic

protected String getTopic()

getPosition

protected PubSubPosition getPosition()

convertVeniceChangeCoordinateToStringAndEncode

public static String convertVeniceChangeCoordinateToStringAndEncode(VeniceChangeCoordinate veniceChangeCoordinate)
                                                             throws IOException

Throws:

IOException

decodeStringAndConvertToVeniceChangeCoordinate

public static VeniceChangeCoordinate decodeStringAndConvertToVeniceChangeCoordinate(String offsetString)
                                                                             throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException