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, subscribedStoreMap, THIN_CLIENT_RETRY_BACKOFF_MS, THIN_CLIENT_RETRY_COUNT

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 SchemaData	getSchemaDataFromSystemStore(java.lang.String storeName)
protected StoreConfig	getStoreConfigFromSystemStore(java.lang.String storeName)
protected Store	getStoreFromSystemStore(java.lang.String storeName, java.lang.String clusterName)
protected StoreMetaValue	getStoreMetaValue(java.lang.String storeName, StoreMetaKey key)
void	subscribe(java.lang.String storeName)

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

getAllStores, getAndCacheSchemaDataFromSystemStore, getAndSetStoreConfigFromSystemStore, getBatchGetLimit, getDerivedSchema, getDerivedSchemaId, getDerivedSchemas, getInstance, getInstance, getKeySchema, getLatestDerivedSchema, getReplicationMetadataSchema, getReplicationMetadataSchemas, getSchemaDataFromMetaSystemStore, getStore, getStoreConfigFromMetaSystemStore, 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 Detail

ThinClientMetaStoreBasedRepository

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

Method Detail

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(java.lang.String storeName)
               throws java.lang.InterruptedException

Specified by:

subscribe in interface SubscriptionBasedReadOnlyStoreRepository

Overrides:

subscribe in class NativeMetadataRepository

Throws:

java.lang.InterruptedException

getStoreConfigFromSystemStore

protected StoreConfig getStoreConfigFromSystemStore(java.lang.String storeName)

Specified by:

getStoreConfigFromSystemStore in class NativeMetadataRepository

getStoreFromSystemStore

protected Store getStoreFromSystemStore(java.lang.String storeName,
                                        java.lang.String clusterName)

Specified by:

getStoreFromSystemStore in class NativeMetadataRepository

getSchemaDataFromSystemStore

protected SchemaData getSchemaDataFromSystemStore(java.lang.String storeName)

Specified by:

getSchemaDataFromSystemStore in class NativeMetadataRepository

getStoreMetaValue

protected StoreMetaValue getStoreMetaValue(java.lang.String storeName,
                                           StoreMetaKey key)

Specified by:

getStoreMetaValue in class NativeMetadataRepository