Package com.linkedin.venice

Class SystemStorePushTask

java.lang.Object

com.linkedin.venice.SystemStorePushTask

All Implemented Interfaces:

Function<String,Boolean>

public class SystemStorePushTask
extends Object
implements Function<String,Boolean>

This class aims to do one time emtpy push to all user system stores of a specific user store. It will aggregate and compute the largest used version from all regions and update store before performing empty push. It will also skip empty push to store which is being migrated and is in the destination cluster.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TASK_NAME

Constructor Summary

Constructors

Constructor	Description
SystemStorePushTask(ControllerClient parentControllerClient, Map<String,ControllerClient> controllerClientMap, String clusterName, Optional<String> systemStoreTypeFilter)

Method Summary

Modifier and Type	Method	Description
Boolean	apply(String storeName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Field Details

TASK_NAME

public static final String TASK_NAME

See Also:

• Constant Field Values

Constructor Details

SystemStorePushTask

public SystemStorePushTask(ControllerClient parentControllerClient,
 Map<String,ControllerClient> controllerClientMap,
 String clusterName,
 Optional<String> systemStoreTypeFilter)

Method Details

apply

public Boolean apply(String storeName)

Specified by:

apply in interface Function<String,Boolean>