Package com.linkedin.venice.beam.consumer

Class CheckPointProperties

java.lang.Object

com.linkedin.venice.beam.consumer.CheckPointProperties

public class CheckPointProperties
extends java.lang.Object

Properties used by VeniceChangelogConsumer to seek checkpoints.

Constructor Summary

Constructors

Constructor	Description
CheckPointProperties(java.util.Set<VeniceChangeCoordinate> coordinates, long seekTimestamp, java.lang.String store)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckPointProperties

public CheckPointProperties(java.util.Set<VeniceChangeCoordinate> coordinates,
                            long seekTimestamp,
                            java.lang.String store)

Method Detail

getCoordinates

public java.util.Set<VeniceChangeCoordinate> getCoordinates()

getSeekTimestamp

public long getSeekTimestamp()

getStore

public java.lang.String getStore()