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 inherited from class com.linkedin.davinci.repository.NativeMetadataRepository

clientConfig, schemaMap, subscribedStoreMap

Constructor Summary

Constructors

Constructor	Description
RequestBasedMetaRepository(ClientConfig clientConfig, VeniceProperties backendConfig, ICProvider icProvider)

Method Summary

Modifier and Type	Method	Description
protected void	cacheStoreSchema(String storeName, StoreMetaValue storeMetaValue)
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 StoreMetaValue	fetchAndCacheStorePropertiesWithICProvider(String storeName)
protected StoreConfig	fetchStoreConfigFromRemote(String storeName)
protected Store	fetchStoreFromRemote(String storeName, String clusterName)
protected TransportClientResponse	fetchStoreProperties(String storeName)
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

Constructor Details

RequestBasedMetaRepository

public RequestBasedMetaRepository(ClientConfig clientConfig,
 VeniceProperties backendConfig,
 ICProvider icProvider)

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

fetchAndCacheStorePropertiesWithICProvider

protected StoreMetaValue fetchAndCacheStorePropertiesWithICProvider(String storeName)

fetchStoreProperties

protected TransportClientResponse fetchStoreProperties(String storeName)

getMaxValueSchemaId

protected int getMaxValueSchemaId(String storeName)

cacheStoreSchema

protected void cacheStoreSchema(String storeName,
 StoreMetaValue storeMetaValue)