Package com.linkedin.venice.beam.consumer

Class CheckPointProperties

java.lang.Object

com.linkedin.venice.beam.consumer.CheckPointProperties

public class CheckPointProperties
extends Object

Properties used by VeniceChangelogConsumer to seek checkpoints.

Constructor Summary

Constructors

Constructor	Description
CheckPointProperties(Set<VeniceChangeCoordinate> coordinates, long seekTimestamp, String store)

Method Summary

Modifier and Type	Method	Description
Set<VeniceChangeCoordinate>	getCoordinates()
long	getSeekTimestamp()
String	getStore()

Methods inherited from class java.lang.Object

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

Constructor Details

CheckPointProperties

public CheckPointProperties(Set<VeniceChangeCoordinate> coordinates,
 long seekTimestamp,
 String store)

Method Details

getCoordinates

public Set<VeniceChangeCoordinate> getCoordinates()

getSeekTimestamp

public long getSeekTimestamp()

getStore

public String getStore()