Package com.linkedin.venice.controller.logcompaction

Class StoreRepushCandidateFilter

java.lang.Object

com.linkedin.venice.controller.logcompaction.StoreRepushCandidateFilter

All Implemented Interfaces:

RepushCandidateFilter

public class StoreRepushCandidateFilter
extends Object
implements RepushCandidateFilter

Prerequisite filter that checks cluster-level and store-level eligibility for log compaction. This filter enforces:

• Cluster-level compaction is enabled
• Store is not a system store
• Store has hybrid config and active-active replication enabled
• Store-level compaction is enabled, store is not migrating, and writes are enabled

Constructor Summary

Constructors

Constructor	Description
StoreRepushCandidateFilter(VeniceControllerMultiClusterConfig multiClusterConfig)

Method Summary

Modifier and Type	Method	Description
boolean	apply(String clusterName, StoreInfo storeInfo)	Defined to implement RepushCandidateFilter interface This function will filter out stores using cluster and store configs

Methods inherited from class java.lang.Object

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

Constructor Details

StoreRepushCandidateFilter

public StoreRepushCandidateFilter(VeniceControllerMultiClusterConfig multiClusterConfig)

Method Details

apply

public boolean apply(String clusterName,
 StoreInfo storeInfo)

Defined to implement RepushCandidateFilter interface This function will filter out stores using cluster and store configs

Specified by:

apply in interface RepushCandidateFilter

Parameters:

clusterName -

storeInfo -

Returns:

true if store should be nominated