StoreUtils (venice API)

java.lang.Object

com.linkedin.venice.utils.StoreUtils

public class StoreUtils extends Object

Constructor Summary

Constructors

Constructor

Description

StoreUtils()
Method Summary

Modifier and Type

Method

Description

static long

getExpectedRetentionTimeInMs(Store store, HybridStoreConfig hybridConfig)

The default retention time for the RT topic is defined in PubSubConstants.DEFAULT_TOPIC_RETENTION_POLICY_MS, but if the rewind time is larger than this, then the RT topic's retention time needs to be set even higher, in order to guarantee that buffer replays do not lose data.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- StoreUtils
  
  public StoreUtils()
Method Details
- getExpectedRetentionTimeInMs
  
  public static long getExpectedRetentionTimeInMs(Store store, HybridStoreConfig hybridConfig)
  
  The default retention time for the RT topic is defined in PubSubConstants.DEFAULT_TOPIC_RETENTION_POLICY_MS, but if the rewind time is larger than this, then the RT topic's retention time needs to be set even higher, in order to guarantee that buffer replays do not lose data. In order to achieve this, the retention time is set to the max of either: 1. PubSubConstants.DEFAULT_TOPIC_RETENTION_POLICY_MS; or 2. HybridStoreConfig.getRewindTimeInSeconds() + Store.getBootstrapToOnlineTimeoutInHours() + 172800000L; This is a convenience function, and thus must be ignored by the JSON machinery.
  
  Returns:
  
  the retention time for the RT topic, in milliseconds.