Package com.linkedin.venice.fastclient.meta

Class RequestBasedMetadata

java.lang.Object

com.linkedin.venice.fastclient.meta.AbstractStoreMetadata

com.linkedin.venice.fastclient.meta.RequestBasedMetadata

All Implemented Interfaces:

StoreMetadata, SchemaReader, Closeable, AutoCloseable

public class RequestBasedMetadata
extends AbstractStoreMetadata

Store metadata class that uses the server's endpoint to fetch metadata and keep the local cache up to date.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_CONN_WARMUP_TIMEOUT_IN_SECONDS_DEFAULT
static final long	DEFAULT_REFRESH_INTERVAL_IN_SECONDS

Fields inherited from class com.linkedin.venice.fastclient.meta.AbstractStoreMetadata

routingStrategy, storeName

Constructor Summary

Constructors

Constructor	Description
RequestBasedMetadata(ClientConfig clientConfig, D2TransportClient d2TransportClient)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getBatchGetLimit()
String	getClusterName()
VeniceCompressor	getCompressor(CompressionStrategy compressionStrategy, int version)
int	getCurrentStoreVersion()
CountDownLatch	getIsReadyLatch()
org.apache.avro.Schema	getKeySchema()
DerivedSchemaEntry	getLatestUpdateSchema()
org.apache.avro.Schema	getLatestValueSchema()
Integer	getLatestValueSchemaId()	Get the latest value schema id.
int	getPartitionId(int version, ByteBuffer key)
long	getRefreshIntervalInSeconds()
List<String>	getReplicas(int version, int partitionId)
ScheduledExecutorService	getScheduler()
org.apache.avro.Schema	getUpdateSchema(int valueSchemaId)
org.apache.avro.Schema	getValueSchema(int id)
int	getValueSchemaId(org.apache.avro.Schema schema)	Return the schema ID of any schema that has the same parsing canonical form as the schema provided.
Map<String,CompletableFuture>	getWarmUpInstancesFutures()
static boolean	isPartitionResourcesReady(String storeName, int version, int partitionCount, Map<Integer,List<String>> routingInfo)
boolean	isReady()
void	setD2ServiceDiscovery(D2ServiceDiscovery d2ServiceDiscovery)	Used for test only
void	setIsReadyLatch(CountDownLatch isReadyLatch)
void	setRefreshIntervalInSeconds(long refreshIntervalInSeconds)
void	setScheduler(ScheduledExecutorService scheduler)
void	setWarmUpInstancesFutures(Map<String,CompletableFuture> warmUpInstancesFutures)
void	start()
static boolean	whetherToSwitchToFetchedCurrentVersion(String storeName, Set<Integer> activeVersions, AtomicInteger currentVersion, int fetchedCurrentVersion, int partitionCountForFetchedCurrentVersion, Map<Integer,List<String>> routingInfo)

Methods inherited from class com.linkedin.venice.fastclient.meta.AbstractStoreMetadata

getCompressor, getInstanceHealthMonitor, getPartitionId, getReplica, getStoreName, routeRequest, setRoutingStrategy, setRoutingStrategy, trackHealthBasedOnRequestToInstance

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.schema.SchemaReader

getLatestValueSchemaId

Field Details

DEFAULT_REFRESH_INTERVAL_IN_SECONDS

public static final long DEFAULT_REFRESH_INTERVAL_IN_SECONDS

See Also:

• Constant Field Values

DEFAULT_CONN_WARMUP_TIMEOUT_IN_SECONDS_DEFAULT

public static final long DEFAULT_CONN_WARMUP_TIMEOUT_IN_SECONDS_DEFAULT

See Also:

• Constant Field Values

Constructor Details

RequestBasedMetadata

public RequestBasedMetadata(ClientConfig clientConfig,
 D2TransportClient d2TransportClient)

Method Details

getClusterName

public String getClusterName()

getCurrentStoreVersion

public int getCurrentStoreVersion()

getPartitionId

public int getPartitionId(int version,
 ByteBuffer key)

getReplicas

public List<String> getReplicas(int version,
 int partitionId)

start

public void start()

whetherToSwitchToFetchedCurrentVersion

public static boolean whetherToSwitchToFetchedCurrentVersion(String storeName,
 Set<Integer> activeVersions,
 AtomicInteger currentVersion,
 int fetchedCurrentVersion,
 int partitionCountForFetchedCurrentVersion,
 Map<Integer,List<String>> routingInfo)

isPartitionResourcesReady

public static boolean isPartitionResourcesReady(String storeName,
 int version,
 int partitionCount,
 Map<Integer,List<String>> routingInfo)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class AbstractStoreMetadata

Throws:

IOException

getCompressor

public VeniceCompressor getCompressor(CompressionStrategy compressionStrategy,
 int version)

getKeySchema

public org.apache.avro.Schema getKeySchema()

getValueSchema

public org.apache.avro.Schema getValueSchema(int id)

getValueSchemaId

public int getValueSchemaId(org.apache.avro.Schema schema)

Description copied from interface: SchemaReader

Return the schema ID of any schema that has the same parsing canonical form as the schema provided. If multiple schemas have the same parsing canonical form, return the one with the largest ID.

Parameters:

schema - The schema for which the schema ID is needed

Returns:

The ID of the schema that has the same parsing canonical form as the schema provided

getLatestValueSchema

public org.apache.avro.Schema getLatestValueSchema()

getLatestValueSchemaId

public Integer getLatestValueSchemaId()

Description copied from interface: SchemaReader

Get the latest value schema id. This may be different from the value schema with the largest id if the superset schema is not the value schema with the largest id

getUpdateSchema

public org.apache.avro.Schema getUpdateSchema(int valueSchemaId)

getLatestUpdateSchema

public DerivedSchemaEntry getLatestUpdateSchema()

isReady

public boolean isReady()

getBatchGetLimit

public int getBatchGetLimit()

Specified by:

getBatchGetLimit in interface StoreMetadata

Overrides:

getBatchGetLimit in class AbstractStoreMetadata

setD2ServiceDiscovery

public void setD2ServiceDiscovery(D2ServiceDiscovery d2ServiceDiscovery)

Used for test only

Parameters:

d2ServiceDiscovery -

setScheduler

public void setScheduler(ScheduledExecutorService scheduler)

getScheduler

public ScheduledExecutorService getScheduler()

setIsReadyLatch

public void setIsReadyLatch(CountDownLatch isReadyLatch)

getIsReadyLatch

public CountDownLatch getIsReadyLatch()

setRefreshIntervalInSeconds

public void setRefreshIntervalInSeconds(long refreshIntervalInSeconds)

getRefreshIntervalInSeconds

public long getRefreshIntervalInSeconds()

getWarmUpInstancesFutures

public Map<String,CompletableFuture> getWarmUpInstancesFutures()

setWarmUpInstancesFutures

public void setWarmUpInstancesFutures(Map<String,CompletableFuture> warmUpInstancesFutures)