Package com.linkedin.davinci.repository

Class RequestBasedMetaRepository

java.lang.Object

com.linkedin.davinci.repository.NativeMetadataRepository

com.linkedin.davinci.repository.RequestBasedMetaRepository

All Implemented Interfaces:

ClusterInfoProvider, ReadOnlySchemaRepository, ReadOnlyStoreRepository, SubscriptionBasedReadOnlyStoreRepository, VeniceResource

public class RequestBasedMetaRepository
extends NativeMetadataRepository

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<String,SchemaData>	storeSchemaMap

Fields inherited from class com.linkedin.davinci.repository.NativeMetadataRepository

clientConfig, schemaMap, subscribedStoreMap

Constructor Summary

Constructors

Constructor	Description
RequestBasedMetaRepository(ClientConfig clientConfig, VeniceProperties backendConfig)

Method Summary

Modifier and Type	Method	Description
protected void	cacheStoreSchema(String storeName, StorePropertiesResponseRecord record)
void	clear()	TODO: we may need to rename this function to be 'close' since this resource should not used any more after calling this function.
protected StorePropertiesResponseRecord	fetchAndCacheStorePropertiesResponseRecord(String storeName)
protected StoreConfig	fetchStoreConfigFromRemote(String storeName)
protected Store	fetchStoreFromRemote(String storeName, String clusterName)
protected int	getMaxValueSchemaId(String storeName)
protected SchemaData	getSchemaData(String storeName)

Methods inherited from class com.linkedin.davinci.repository.NativeMetadataRepository

cacheStoreConfigFromRemote, getAllStores, getAndCacheSchemaData, getBatchGetLimit, getDerivedSchema, getDerivedSchemaId, getDerivedSchemas, getInstance, getInstance, getKeySchema, getLatestDerivedSchema, getReplicationMetadataSchema, getReplicationMetadataSchemas, getStore, getStoreOrThrow, getSupersetOrLatestValueSchema, getSupersetSchema, getTotalStoreReadQuota, getValueSchema, getValueSchemaId, getValueSchemaInternally, getValueSchemas, getVeniceCluster, hasStore, hasValueSchema, isReadComputationEnabled, notifyStoreChanged, notifyStoreCreated, notifyStoreDeleted, putStore, refresh, refreshOneStore, registerStoreDataChangedListener, removeStore, removeStoreSchema, start, subscribe, unregisterStoreDataChangedListener, unsubscribe

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.meta.ReadOnlySchemaRepository

getLatestDerivedSchema

Methods inherited from interface com.linkedin.venice.meta.ReadOnlyStoreRepository

waitVersion, waitVersion

Field Details

storeSchemaMap

protected Map<String,SchemaData> storeSchemaMap

Constructor Details

RequestBasedMetaRepository

public RequestBasedMetaRepository(ClientConfig clientConfig,
 VeniceProperties backendConfig)

Method Details

clear

public void clear()

Description copied from class: NativeMetadataRepository

TODO: we may need to rename this function to be 'close' since this resource should not used any more after calling this function.

Specified by:

clear in interface VeniceResource

Overrides:

clear in class NativeMetadataRepository

fetchStoreConfigFromRemote

protected StoreConfig fetchStoreConfigFromRemote(String storeName)

Specified by:

fetchStoreConfigFromRemote in class NativeMetadataRepository

fetchStoreFromRemote

protected Store fetchStoreFromRemote(String storeName,
 String clusterName)

Specified by:

fetchStoreFromRemote in class NativeMetadataRepository

getSchemaData

protected SchemaData getSchemaData(String storeName)

Specified by:

getSchemaData in class NativeMetadataRepository

fetchAndCacheStorePropertiesResponseRecord

protected StorePropertiesResponseRecord fetchAndCacheStorePropertiesResponseRecord(String storeName)

getMaxValueSchemaId

protected int getMaxValueSchemaId(String storeName)

cacheStoreSchema

protected void cacheStoreSchema(String storeName,
 StorePropertiesResponseRecord record)