Package com.linkedin.davinci.repository

Class ThinClientMetaStoreBasedRepository

java.lang.Object

com.linkedin.davinci.repository.NativeMetadataRepository

com.linkedin.davinci.repository.ThinClientMetaStoreBasedRepository

All Implemented Interfaces:

ClusterInfoProvider, ReadOnlySchemaRepository, ReadOnlyStoreRepository, SubscriptionBasedReadOnlyStoreRepository, VeniceResource

public class ThinClientMetaStoreBasedRepository
extends NativeMetadataRepository

Field Summary

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

clientConfig, schemaMap, subscribedStoreMap

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
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 StoreConfig	fetchStoreConfigFromRemote(String storeName)
protected Store	fetchStoreFromRemote(String storeName, String clusterName)
protected SchemaData	getSchemaData(String storeName)
protected StoreMetaValue	getStoreMetaValue(String storeName, StoreMetaKey key)
void	subscribe(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, 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

ThinClientMetaStoreBasedRepository

public ThinClientMetaStoreBasedRepository(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

subscribe

public void subscribe(String storeName)
               throws InterruptedException

Specified by:

subscribe in interface SubscriptionBasedReadOnlyStoreRepository

Overrides:

subscribe in class NativeMetadataRepository

Throws:

InterruptedException

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

getStoreMetaValue

protected StoreMetaValue getStoreMetaValue(String storeName,
 StoreMetaKey key)

getSchemaData

protected SchemaData getSchemaData(String storeName)

Specified by:

getSchemaData in class NativeMetadataRepository