Package com.linkedin.venice.controller.util

Class ParentControllerConfigUpdateUtils

java.lang.Object

com.linkedin.venice.controller.util.ParentControllerConfigUpdateUtils

public class ParentControllerConfigUpdateUtils
extends Object

This class is a utility class for Parent Controller store update logics. The method here aims to take in current status and request params to determine if certain feature is updated / should be updated based on some customized logics.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.logging.log4j.Logger	LOGGER
static final WriteComputeSchemaConverter	updateSchemaConverter

Constructor Summary

Constructors

Constructor	Description
ParentControllerConfigUpdateUtils()

Method Summary

Modifier and Type	Method	Description
static void	addUpdateSchemaForStore(VeniceParentHelixAdmin parentHelixAdmin, String clusterName, String storeName, boolean dryRun)
static boolean	checkAndMaybeApplyChunkingConfigChange(VeniceParentHelixAdmin parentHelixAdmin, String clusterName, String storeName, Optional<Boolean> chunkingRequest, UpdateStore setStore)
static boolean	checkAndMaybeApplyPartialUpdateConfig(VeniceParentHelixAdmin parentHelixAdmin, String clusterName, String storeName, Optional<Boolean> partialUpdateRequest, UpdateStore setStore, boolean storeBeingConvertedToHybrid)	This method takes in current status and request and try to determine whether to change partial update config.
static boolean	checkAndMaybeApplyRmdChunkingConfigChange(VeniceParentHelixAdmin parentHelixAdmin, String clusterName, String storeName, Optional<Boolean> rmdChunkingRequest, UpdateStore setStore)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

public static final org.apache.logging.log4j.Logger LOGGER

updateSchemaConverter

public static final WriteComputeSchemaConverter updateSchemaConverter

Constructor Details

ParentControllerConfigUpdateUtils

public ParentControllerConfigUpdateUtils()

Method Details

checkAndMaybeApplyPartialUpdateConfig

public static boolean checkAndMaybeApplyPartialUpdateConfig(VeniceParentHelixAdmin parentHelixAdmin,
 String clusterName,
 String storeName,
 Optional<Boolean> partialUpdateRequest,
 UpdateStore setStore,
 boolean storeBeingConvertedToHybrid)

This method takes in current status and request and try to determine whether to change partial update config. The check logic is: Step (1): If there is explict request, we will respect the request and maybe update config if new request value is different from existing config value. In this step, if we are enabling partial update, we will also perform a dry run to validate schema. If validation fails, it will throw exception and fail the whole request. Step (2): If there is NO explict request and store is being converted into hybrid store, we will check the cluster config and store's latest A/A config to see whether we should by default enable partial update. If so, we will also perform a dry on to validate schema. If validation fails, it will swallow the exception and log warning message. It will not turn on partial update and will not fail the whole request.

checkAndMaybeApplyChunkingConfigChange

public static boolean checkAndMaybeApplyChunkingConfigChange(VeniceParentHelixAdmin parentHelixAdmin,
 String clusterName,
 String storeName,
 Optional<Boolean> chunkingRequest,
 UpdateStore setStore)

checkAndMaybeApplyRmdChunkingConfigChange

public static boolean checkAndMaybeApplyRmdChunkingConfigChange(VeniceParentHelixAdmin parentHelixAdmin,
 String clusterName,
 String storeName,
 Optional<Boolean> rmdChunkingRequest,
 UpdateStore setStore)

addUpdateSchemaForStore

public static void addUpdateSchemaForStore(VeniceParentHelixAdmin parentHelixAdmin,
 String clusterName,
 String storeName,
 boolean dryRun)