Package com.linkedin.venice.controller.logcompaction

Class VersionStalenessTrigger

java.lang.Object

com.linkedin.venice.controller.logcompaction.VersionStalenessTrigger

All Implemented Interfaces:

RepushCandidateTrigger

public class VersionStalenessTrigger
extends Object
implements RepushCandidateTrigger

Trigger that checks whether a store's latest version is stale enough to warrant compaction. As a RepushCandidateTrigger, this participates in OR logic with other triggers — if any trigger passes, the store is scheduled for compaction (provided all prerequisite filters also pass).

Constructor Summary

Constructors

Constructor	Description
VersionStalenessTrigger(VeniceControllerMultiClusterConfig multiClusterConfig)

Method Summary

Modifier and Type	Method	Description
boolean	apply(String clusterName, StoreInfo storeInfo)

Methods inherited from class java.lang.Object

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

Constructor Details

VersionStalenessTrigger

public VersionStalenessTrigger(VeniceControllerMultiClusterConfig multiClusterConfig)

Method Details

apply

public boolean apply(String clusterName,
 StoreInfo storeInfo)

Specified by:

apply in interface RepushCandidateTrigger