Package com.linkedin.venice.controller

Class HybridStoreConfigPolicy

java.lang.Object

com.linkedin.venice.controller.HybridStoreConfigPolicy

public final class HybridStoreConfigPolicy
extends Object

Encodes Venice's policy for hybrid + replication configuration on a store: when a store counts as hybrid, how user-supplied update options merge onto the existing config, and the auto-enable / auto-disable rules at hybrid <-> batch transitions. Pure computation against in-memory state; no I/O.

Method Summary

Modifier and Type	Method	Description
static boolean	applyHybridAndReplicationConfigUpdates(String storeName, Store currStore, UpdateStore setStore, VeniceControllerClusterConfig controllerConfig, Optional<Long> hybridRewindSeconds, Optional<Long> hybridOffsetLagThreshold, Optional<Long> hybridTimeLagThreshold, Optional<DataReplicationPolicy> hybridDataReplicationPolicy, Optional<BufferReplayPolicy> hybridBufferReplayPolicy, Optional<String> realTimeTopicName, Optional<Boolean> activeActiveReplicationEnabled, Optional<Boolean> incrementalPushEnabled, List<CharSequence> updatedConfigsList, org.apache.logging.log4j.Logger logger)	Apply user-supplied hybrid + replication updates to setStore, return whether the store is being converted from batch to hybrid.
static boolean	isHybrid(HybridStoreConfigRecord hybridStoreConfigRecord)
static boolean	isHybrid(HybridStoreConfig hybridStoreConfig)	A store is hybrid iff its HybridStoreConfig is non-null and at least one of the rewind / offset-lag / time-lag thresholds is non-negative.
static HybridStoreConfig	mergeNewSettingsIntoOldHybridStoreConfig(Store oldStore, Optional<Long> hybridRewindSeconds, Optional<Long> hybridOffsetLagThreshold, Optional<Long> hybridTimeLagThreshold, Optional<DataReplicationPolicy> hybridDataReplicationPolicy, Optional<BufferReplayPolicy> bufferReplayPolicy, Optional<String> realTimeTopicName)	Merge user-supplied hybrid options on top of oldStore's current hybrid config.

Methods inherited from class java.lang.Object

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

Method Details

isHybrid

public static boolean isHybrid(HybridStoreConfig hybridStoreConfig)

A store is hybrid iff its HybridStoreConfig is non-null and at least one of the rewind / offset-lag / time-lag thresholds is non-negative. A negative threshold sentinel is how a store is set back to batch-only.

isHybrid

public static boolean isHybrid(HybridStoreConfigRecord hybridStoreConfigRecord)

See Also:

• isHybrid(HybridStoreConfig)

mergeNewSettingsIntoOldHybridStoreConfig

public static HybridStoreConfig mergeNewSettingsIntoOldHybridStoreConfig(Store oldStore,
 Optional<Long> hybridRewindSeconds,
 Optional<Long> hybridOffsetLagThreshold,
 Optional<Long> hybridTimeLagThreshold,
 Optional<DataReplicationPolicy> hybridDataReplicationPolicy,
 Optional<BufferReplayPolicy> bufferReplayPolicy,
 Optional<String> realTimeTopicName)

Merge user-supplied hybrid options on top of oldStore's current hybrid config.

Returns null when oldStore is currently batch-only and no hybrid option has been specified (i.e. the caller is not converting the store to hybrid). When converting a batch-only store to hybrid, the rewind time plus at least one of the lag thresholds must be specified, otherwise VeniceException is thrown.

applyHybridAndReplicationConfigUpdates

public static boolean applyHybridAndReplicationConfigUpdates(String storeName,
 Store currStore,
 UpdateStore setStore,
 VeniceControllerClusterConfig controllerConfig,
 Optional<Long> hybridRewindSeconds,
 Optional<Long> hybridOffsetLagThreshold,
 Optional<Long> hybridTimeLagThreshold,
 Optional<DataReplicationPolicy> hybridDataReplicationPolicy,
 Optional<BufferReplayPolicy> hybridBufferReplayPolicy,
 Optional<String> realTimeTopicName,
 Optional<Boolean> activeActiveReplicationEnabled,
 Optional<Boolean> incrementalPushEnabled,
 List<CharSequence> updatedConfigsList,
 org.apache.logging.log4j.Logger logger)

Apply user-supplied hybrid + replication updates to setStore, return whether the store is being converted from batch to hybrid. Mutates setStore and updatedConfigsList; performs no I/O.