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
All Methods Instance Methods Concrete Methods 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 interfaceVeniceResource
- Overrides:
clear
in classNativeMetadataRepository
-
subscribe
public void subscribe(java.lang.String storeName) throws java.lang.InterruptedException
- Specified by:
subscribe
in interfaceSubscriptionBasedReadOnlyStoreRepository
- Overrides:
subscribe
in classNativeMetadataRepository
- Throws:
java.lang.InterruptedException
-
getStoreConfigFromSystemStore
protected StoreConfig getStoreConfigFromSystemStore(java.lang.String storeName)
- Specified by:
getStoreConfigFromSystemStore
in classNativeMetadataRepository
-
getStoreFromSystemStore
protected Store getStoreFromSystemStore(java.lang.String storeName, java.lang.String clusterName)
- Specified by:
getStoreFromSystemStore
in classNativeMetadataRepository
-
getSchemaDataFromSystemStore
protected SchemaData getSchemaDataFromSystemStore(java.lang.String storeName)
- Specified by:
getSchemaDataFromSystemStore
in classNativeMetadataRepository
-
getStoreMetaValue
protected StoreMetaValue getStoreMetaValue(java.lang.String storeName, StoreMetaKey key)
- Specified by:
getStoreMetaValue
in classNativeMetadataRepository
-
-