Package com.linkedin.venice.fastclient

Class ClientConfig.ClientConfigBuilder<K,V,T extends org.apache.avro.specific.SpecificRecord>

java.lang.Object

com.linkedin.venice.fastclient.ClientConfig.ClientConfigBuilder<K,V,T>

Enclosing class:

ClientConfig<K,V,T extends org.apache.avro.specific.SpecificRecord>

public static class ClientConfig.ClientConfigBuilder<K,V,T extends org.apache.avro.specific.SpecificRecord>
extends Object

Constructor Summary

Constructors

Constructor	Description
ClientConfigBuilder()

Method Summary

Modifier and Type	Method	Description
ClientConfig<K,V,T>	build()
ClientConfig.ClientConfigBuilder<K,V,T>	clone()
ClientConfig.ClientConfigBuilder<K,V,T>	setClientRoutingStrategyType(ClientRoutingStrategyType clientRoutingStrategyType)
ClientConfig.ClientConfigBuilder<K,V,T>	setClusterDiscoveryD2Service(String clusterDiscoveryD2Service)
ClientConfig.ClientConfigBuilder<K,V,T>	setD2Client(com.linkedin.d2.balancer.D2Client d2Client)
ClientConfig.ClientConfigBuilder<K,V,T>	setDaVinciClientForMetaStore(DaVinciClient<StoreMetaKey,StoreMetaValue> daVinciClientForMetaStore)
ClientConfig.ClientConfigBuilder<K,V,T>	setDeserializationExecutor(Executor deserializationExecutor)
ClientConfig.ClientConfigBuilder<K,V,T>	setDualReadEnabled(boolean dualReadEnabled)
ClientConfig.ClientConfigBuilder<K,V,T>	setEnableLeastLoadedRoutingStrategyForHelixGroupRouting(boolean enableLeastLoadedRoutingStrategyForHelixGroupRouting)
ClientConfig.ClientConfigBuilder<K,V,T>	setGenericThinClient(AvroGenericStoreClient<K,V> genericThinClient)
ClientConfig.ClientConfigBuilder<K,V,T>	setGrpcClientConfig(GrpcClientConfig grpcClientConfig)
ClientConfig.ClientConfigBuilder<K,V,T>	setHARClusters(Set<String> clusters)
ClientConfig.ClientConfigBuilder<K,V,T>	setInstanceHealthMonitor(InstanceHealthMonitor instanceHealthMonitor)
ClientConfig.ClientConfigBuilder<K,V,T>	setIsMetadataConnWarmupEnabled(boolean isMetadataConnWarmupEnabled)
ClientConfig.ClientConfigBuilder<K,V,T>	setKeySerializerFactory(SerializerFactory<K> keySerializerFactory)	Set a custom key serializer factory.
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRangeBasedRetryThresholdForBatchGetInMilliSeconds(String longTailRangeBasedRetryThresholdForBatchGetInMilliSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRangeBasedRetryThresholdForComputeInMilliSeconds(String longTailRangeBasedRetryThresholdForComputeInMilliSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryBudgetEnforcementWindowInMs(long longTailRetryBudgetEnforcementWindowInMs)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryEnabledForBatchGet(boolean longTailRetryEnabledForBatchGet)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryEnabledForCompute(boolean longTailRetryEnabledForCompute)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryEnabledForSingleGet(boolean longTailRetryEnabledForSingleGet)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryThresholdForBatchGetInMicroSeconds(int longTailRetryThresholdForBatchGetInMicroSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setLongTailRetryThresholdForSingleGetInMicroSeconds(int longTailRetryThresholdForSingleGetInMicroSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setMetadataConnWarmupTimeoutInSeconds(long metadataConnWarmupTimeoutInSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setMetadataRefreshExecutor(ScheduledExecutorService metadataRefreshExecutor)
ClientConfig.ClientConfigBuilder<K,V,T>	setMetadataRefreshIntervalInSeconds(long metadataRefreshIntervalInSeconds)
ClientConfig.ClientConfigBuilder<K,V,T>	setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)
ClientConfig.ClientConfigBuilder<K,V,T>	setProjectionFieldValidationEnabled(boolean projectionFieldValidation)
ClientConfig.ClientConfigBuilder<K,V,T>	setR2Client(com.linkedin.r2.transport.common.Client r2Client)
ClientConfig.ClientConfigBuilder<K,V,T>	setRetryBudgetEnabled(boolean retryBudgetEnabled)
ClientConfig.ClientConfigBuilder<K,V,T>	setRetryBudgetPercentage(double retryBudgetPercentage)
ClientConfig.ClientConfigBuilder<K,V,T>	setSpecificThinClient(AvroSpecificStoreClient<K,T> specificThinClient)
ClientConfig.ClientConfigBuilder<K,V,T>	setSpecificValueClass(Class<T> specificValueClass)
ClientConfig.ClientConfigBuilder<K,V,T>	setStatsPrefix(String statsPrefix)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreLoadControllerAcceptMultiplier(double storeLoadControllerAcceptMultiplier)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreLoadControllerEnabled(boolean storeLoadControllerEnabled)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreLoadControllerMaxRejectionRatio(double storeLoadControllerMaxRejectionRatio)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreLoadControllerRejectionRatioUpdateIntervalInSec(int storeLoadControllerRejectionRatioUpdateIntervalInSec)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreLoadControllerWindowSizeInSec(int storeLoadControllerWindowSizeInSec)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreMetadataFetchMode(StoreMetadataFetchMode storeMetadataFetchMode)
ClientConfig.ClientConfigBuilder<K,V,T>	setStoreName(String storeName)
ClientConfig.ClientConfigBuilder<K,V,T>	setThinClientForMetaStore(AvroSpecificStoreClient<StoreMetaKey,StoreMetaValue> thinClientForMetaStore)
ClientConfig.ClientConfigBuilder<K,V,T>	setUseGrpc(boolean useGrpc)
ClientConfig.ClientConfigBuilder<K,V,T>	setValueDeserializerFactory(DeserializerFactory<V> valueDeserializerFactory)	Set a custom value deserializer factory.
ClientConfig.ClientConfigBuilder<K,V,T>	setVsonStore(boolean vsonStore)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Details

ClientConfigBuilder

public ClientConfigBuilder()

Method Details

setStoreName

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreName(String storeName)

setMetricsRepository

public ClientConfig.ClientConfigBuilder<K,V,T> setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository)

setStatsPrefix

public ClientConfig.ClientConfigBuilder<K,V,T> setStatsPrefix(String statsPrefix)

setSpecificValueClass

public ClientConfig.ClientConfigBuilder<K,V,T> setSpecificValueClass(Class<T> specificValueClass)

setDeserializationExecutor

public ClientConfig.ClientConfigBuilder<K,V,T> setDeserializationExecutor(Executor deserializationExecutor)

setMetadataRefreshExecutor

public ClientConfig.ClientConfigBuilder<K,V,T> setMetadataRefreshExecutor(ScheduledExecutorService metadataRefreshExecutor)

setClientRoutingStrategyType

public ClientConfig.ClientConfigBuilder<K,V,T> setClientRoutingStrategyType(ClientRoutingStrategyType clientRoutingStrategyType)

setR2Client

public ClientConfig.ClientConfigBuilder<K,V,T> setR2Client(com.linkedin.r2.transport.common.Client r2Client)

setDualReadEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setDualReadEnabled(boolean dualReadEnabled)

setGenericThinClient

public ClientConfig.ClientConfigBuilder<K,V,T> setGenericThinClient(AvroGenericStoreClient<K,V> genericThinClient)

setSpecificThinClient

public ClientConfig.ClientConfigBuilder<K,V,T> setSpecificThinClient(AvroSpecificStoreClient<K,T> specificThinClient)

setDaVinciClientForMetaStore

public ClientConfig.ClientConfigBuilder<K,V,T> setDaVinciClientForMetaStore(DaVinciClient<StoreMetaKey,StoreMetaValue> daVinciClientForMetaStore)

setThinClientForMetaStore

public ClientConfig.ClientConfigBuilder<K,V,T> setThinClientForMetaStore(AvroSpecificStoreClient<StoreMetaKey,StoreMetaValue> thinClientForMetaStore)

setIsMetadataConnWarmupEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setIsMetadataConnWarmupEnabled(boolean isMetadataConnWarmupEnabled)

setMetadataRefreshIntervalInSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setMetadataRefreshIntervalInSeconds(long metadataRefreshIntervalInSeconds)

setMetadataConnWarmupTimeoutInSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setMetadataConnWarmupTimeoutInSeconds(long metadataConnWarmupTimeoutInSeconds)

setLongTailRetryEnabledForSingleGet

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryEnabledForSingleGet(boolean longTailRetryEnabledForSingleGet)

setLongTailRetryThresholdForSingleGetInMicroSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryThresholdForSingleGetInMicroSeconds(int longTailRetryThresholdForSingleGetInMicroSeconds)

setLongTailRetryEnabledForBatchGet

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryEnabledForBatchGet(boolean longTailRetryEnabledForBatchGet)

setLongTailRetryThresholdForBatchGetInMicroSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryThresholdForBatchGetInMicroSeconds(int longTailRetryThresholdForBatchGetInMicroSeconds)

setLongTailRetryEnabledForCompute

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryEnabledForCompute(boolean longTailRetryEnabledForCompute)

setVsonStore

@Deprecated
public ClientConfig.ClientConfigBuilder<K,V,T> setVsonStore(boolean vsonStore)

Deprecated.

setStoreMetadataFetchMode

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreMetadataFetchMode(StoreMetadataFetchMode storeMetadataFetchMode)

setD2Client

public ClientConfig.ClientConfigBuilder<K,V,T> setD2Client(com.linkedin.d2.balancer.D2Client d2Client)

setClusterDiscoveryD2Service

public ClientConfig.ClientConfigBuilder<K,V,T> setClusterDiscoveryD2Service(String clusterDiscoveryD2Service)

setUseGrpc

public ClientConfig.ClientConfigBuilder<K,V,T> setUseGrpc(boolean useGrpc)

setGrpcClientConfig

public ClientConfig.ClientConfigBuilder<K,V,T> setGrpcClientConfig(GrpcClientConfig grpcClientConfig)

setProjectionFieldValidationEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setProjectionFieldValidationEnabled(boolean projectionFieldValidation)

setLongTailRetryBudgetEnforcementWindowInMs

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRetryBudgetEnforcementWindowInMs(long longTailRetryBudgetEnforcementWindowInMs)

setHARClusters

public ClientConfig.ClientConfigBuilder<K,V,T> setHARClusters(Set<String> clusters)

setInstanceHealthMonitor

public ClientConfig.ClientConfigBuilder<K,V,T> setInstanceHealthMonitor(InstanceHealthMonitor instanceHealthMonitor)

setRetryBudgetEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setRetryBudgetEnabled(boolean retryBudgetEnabled)

setRetryBudgetPercentage

public ClientConfig.ClientConfigBuilder<K,V,T> setRetryBudgetPercentage(double retryBudgetPercentage)

setEnableLeastLoadedRoutingStrategyForHelixGroupRouting

public ClientConfig.ClientConfigBuilder<K,V,T> setEnableLeastLoadedRoutingStrategyForHelixGroupRouting(boolean enableLeastLoadedRoutingStrategyForHelixGroupRouting)

setStoreLoadControllerEnabled

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreLoadControllerEnabled(boolean storeLoadControllerEnabled)

setStoreLoadControllerWindowSizeInSec

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreLoadControllerWindowSizeInSec(int storeLoadControllerWindowSizeInSec)

setStoreLoadControllerRejectionRatioUpdateIntervalInSec

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreLoadControllerRejectionRatioUpdateIntervalInSec(int storeLoadControllerRejectionRatioUpdateIntervalInSec)

setStoreLoadControllerMaxRejectionRatio

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreLoadControllerMaxRejectionRatio(double storeLoadControllerMaxRejectionRatio)

setStoreLoadControllerAcceptMultiplier

public ClientConfig.ClientConfigBuilder<K,V,T> setStoreLoadControllerAcceptMultiplier(double storeLoadControllerAcceptMultiplier)

setLongTailRangeBasedRetryThresholdForBatchGetInMilliSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRangeBasedRetryThresholdForBatchGetInMilliSeconds(String longTailRangeBasedRetryThresholdForBatchGetInMilliSeconds)

setLongTailRangeBasedRetryThresholdForComputeInMilliSeconds

public ClientConfig.ClientConfigBuilder<K,V,T> setLongTailRangeBasedRetryThresholdForComputeInMilliSeconds(String longTailRangeBasedRetryThresholdForComputeInMilliSeconds)

setKeySerializerFactory

public ClientConfig.ClientConfigBuilder<K,V,T> setKeySerializerFactory(SerializerFactory<K> keySerializerFactory)

Set a custom key serializer factory. This allows using custom serialization formats (e.g., Protocol Buffers) instead of Avro.

Parameters:

keySerializerFactory - the factory to create key serializers, or null to use default Avro serializers

Returns:

this builder

setValueDeserializerFactory

public ClientConfig.ClientConfigBuilder<K,V,T> setValueDeserializerFactory(DeserializerFactory<V> valueDeserializerFactory)

Set a custom value deserializer factory. This allows using custom deserialization formats (e.g., Protocol Buffers) instead of Avro.

Parameters:

valueDeserializerFactory - the factory to create value deserializers, or null to use default Avro deserializers

Returns:

this builder

clone

public ClientConfig.ClientConfigBuilder<K,V,T> clone()

Overrides:

clone in class Object

build

public ClientConfig<K,V,T> build()