Package com.linkedin.venice.meta

Class HybridStoreConfigImpl

java.lang.Object

com.linkedin.venice.meta.HybridStoreConfigImpl

All Implemented Interfaces:

DataModelBackedStructure<StoreHybridConfig>, HybridStoreConfig

public class HybridStoreConfigImpl
extends Object
implements HybridStoreConfig

A container of Hybrid Store related configurations.

Field Summary

Fields

Modifier and Type	Field	Description
static final DataReplicationPolicy	DEFAULT_DATA_REPLICATION_POLICY
static final long	DEFAULT_HYBRID_OFFSET_LAG_THRESHOLD
static final long	DEFAULT_HYBRID_TIME_LAG_THRESHOLD
static final String	DEFAULT_REAL_TIME_TOPIC_NAME
static final long	DEFAULT_REWIND_TIME_IN_SECONDS

Constructor Summary

Constructors

Constructor	Description
HybridStoreConfigImpl(long rewindTimeInSeconds, long offsetLagThresholdToGoOnline, long producerTimestampLagThresholdToGoOnlineInSeconds, BufferReplayPolicy bufferReplayPolicy)
HybridStoreConfigImpl(long rewindTimeInSeconds, long offsetLagThresholdToGoOnline, long producerTimestampLagThresholdToGoOnlineInSeconds, DataReplicationPolicy dataReplicationPolicy, BufferReplayPolicy bufferReplayPolicy, String realTimeTopicName)

Method Summary

Modifier and Type	Method	Description
HybridStoreConfig	clone()
StoreHybridConfig	dataModel()	Return the backed data model.
boolean	equals(Object o)
BufferReplayPolicy	getBufferReplayPolicy()
DataReplicationPolicy	getDataReplicationPolicy()
long	getOffsetLagThresholdToGoOnline()
long	getProducerTimestampLagThresholdToGoOnlineInSeconds()
String	getRealTimeTopicName()
long	getRewindTimeInSeconds()
int	hashCode()
void	setDataReplicationPolicy(DataReplicationPolicy dataReplicationPolicy)
void	setOffsetLagThresholdToGoOnline(long offsetLagThresholdToGoOnline)
void	setRealTimeTopicName(String realTimeTopicName)
void	setRewindTimeInSeconds(long rewindTimeInSeconds)

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_REWIND_TIME_IN_SECONDS

public static final long DEFAULT_REWIND_TIME_IN_SECONDS

See Also:

• Constant Field Values

DEFAULT_HYBRID_TIME_LAG_THRESHOLD

public static final long DEFAULT_HYBRID_TIME_LAG_THRESHOLD

See Also:

• Constant Field Values

DEFAULT_HYBRID_OFFSET_LAG_THRESHOLD

public static final long DEFAULT_HYBRID_OFFSET_LAG_THRESHOLD

See Also:

• Constant Field Values

DEFAULT_REAL_TIME_TOPIC_NAME

public static final String DEFAULT_REAL_TIME_TOPIC_NAME

See Also:

• Constant Field Values

DEFAULT_DATA_REPLICATION_POLICY

public static final DataReplicationPolicy DEFAULT_DATA_REPLICATION_POLICY

Constructor Details

HybridStoreConfigImpl

public HybridStoreConfigImpl(long rewindTimeInSeconds,
 long offsetLagThresholdToGoOnline,
 long producerTimestampLagThresholdToGoOnlineInSeconds,
 BufferReplayPolicy bufferReplayPolicy)

HybridStoreConfigImpl

public HybridStoreConfigImpl(long rewindTimeInSeconds,
 long offsetLagThresholdToGoOnline,
 long producerTimestampLagThresholdToGoOnlineInSeconds,
 DataReplicationPolicy dataReplicationPolicy,
 BufferReplayPolicy bufferReplayPolicy,
 String realTimeTopicName)

Method Details

getRewindTimeInSeconds

public long getRewindTimeInSeconds()

Specified by:

getRewindTimeInSeconds in interface HybridStoreConfig

getOffsetLagThresholdToGoOnline

public long getOffsetLagThresholdToGoOnline()

Specified by:

getOffsetLagThresholdToGoOnline in interface HybridStoreConfig

setRewindTimeInSeconds

public void setRewindTimeInSeconds(long rewindTimeInSeconds)

Specified by:

setRewindTimeInSeconds in interface HybridStoreConfig

setOffsetLagThresholdToGoOnline

public void setOffsetLagThresholdToGoOnline(long offsetLagThresholdToGoOnline)

Specified by:

setOffsetLagThresholdToGoOnline in interface HybridStoreConfig

getProducerTimestampLagThresholdToGoOnlineInSeconds

public long getProducerTimestampLagThresholdToGoOnlineInSeconds()

Specified by:

getProducerTimestampLagThresholdToGoOnlineInSeconds in interface HybridStoreConfig

getDataReplicationPolicy

public DataReplicationPolicy getDataReplicationPolicy()

Specified by:

getDataReplicationPolicy in interface HybridStoreConfig

setDataReplicationPolicy

public void setDataReplicationPolicy(DataReplicationPolicy dataReplicationPolicy)

Specified by:

setDataReplicationPolicy in interface HybridStoreConfig

getBufferReplayPolicy

public BufferReplayPolicy getBufferReplayPolicy()

Specified by:

getBufferReplayPolicy in interface HybridStoreConfig

getRealTimeTopicName

public String getRealTimeTopicName()

Specified by:

getRealTimeTopicName in interface HybridStoreConfig

setRealTimeTopicName

public void setRealTimeTopicName(String realTimeTopicName)

Specified by:

setRealTimeTopicName in interface HybridStoreConfig

dataModel

public StoreHybridConfig dataModel()

Description copied from interface: DataModelBackedStructure

Return the backed data model.

Specified by:

dataModel in interface DataModelBackedStructure<StoreHybridConfig>

Returns:

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

clone

public HybridStoreConfig clone()

Specified by:

clone in interface HybridStoreConfig

Overrides:

clone in class Object