Package com.linkedin.venice.helix

Class CachedReadOnlyStoreRepository

java.lang.Object

com.linkedin.venice.helix.CachedReadOnlyStoreRepository

All Implemented Interfaces:

ReadOnlyStoreRepository, VeniceResource

Direct Known Subclasses:

HelixReadOnlyStoreRepository, HelixReadWriteStoreRepository

public class CachedReadOnlyStoreRepository
extends Object
implements ReadOnlyStoreRepository

Field Summary

Fields

Modifier and Type	Field	Description
protected final ClusterLockManager	clusterLockManager
protected final String	clusterName
protected final String	clusterStoreRepositoryPath
static final String	STORE_REPOSITORY_PATH
protected final Map<String,Store>	storeMap
protected final org.apache.helix.zookeeper.impl.client.ZkClient	zkClient
protected final org.apache.helix.manager.zk.ZkBaseDataAccessor<Store>	zkDataAccessor

Constructor Summary

Constructors

Constructor	Description
CachedReadOnlyStoreRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, String clusterName, HelixAdapterSerializer compositeSerializer, ClusterLockManager clusterLockManager)

Method Summary

Modifier and Type	Method	Description
void	clear()
List<Store>	getAllStores()	Get all stores in the current repository
int	getBatchGetLimit(String storeName)	Get batch-get limit for the specified store
Store	getStore(String storeName)	Get one store by given name from repository.
protected Store	getStoreFromZk(String storeName)
Store	getStoreOrThrow(String storeName)
protected List<Store>	getStoresFromZk()	HelixReadOnlyZKSharedSystemStoreRepository is overriding this function to filter out stores, which are not necessary to put a watch against during refresh(), and if this logic to refresh the zk store repository gets changed in the future, we need to update HelixReadOnlyZKSharedSystemStoreRepository accordingly.
protected List<Store>	getStoresFromZk(Collection<String> storeNames)
protected final String	getStoreZkPath(String storeName)
long	getTotalStoreReadQuota()	Get total read quota of all stores.
boolean	hasStore(String storeName)	Whether the store exists or not.
boolean	isReadComputationEnabled(String storeName)	Whether computation is enabled for the specified store.
protected void	notifyStoreChanged(Store store)
protected void	notifyStoreCreated(Store store)
protected void	notifyStoreDeleted(Store store)
protected Store	putStore(Store newStore)
void	refresh()
Store	refreshOneStore(String storeName)	Selective refresh operation which fetches one store from ZK
void	registerStoreDataChangedListener(StoreDataChangedListener listener)	Register store data change listener.
protected Store	removeStore(String storeName)
void	unregisterStoreDataChangedListener(StoreDataChangedListener listener)	Unregister store data change listener.

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.ReadOnlyStoreRepository

waitVersion, waitVersion

Field Details

STORE_REPOSITORY_PATH

public static final String STORE_REPOSITORY_PATH

See Also:

• Constant Field Values

clusterName

protected final String clusterName

clusterStoreRepositoryPath

protected final String clusterStoreRepositoryPath

zkClient

protected final org.apache.helix.zookeeper.impl.client.ZkClient zkClient

zkDataAccessor

protected final org.apache.helix.manager.zk.ZkBaseDataAccessor<Store> zkDataAccessor

clusterLockManager

protected final ClusterLockManager clusterLockManager

storeMap

protected final Map<String,Store> storeMap

Constructor Details

CachedReadOnlyStoreRepository

public CachedReadOnlyStoreRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 String clusterName,
 HelixAdapterSerializer compositeSerializer,
 ClusterLockManager clusterLockManager)

Method Details

getStore

public Store getStore(String storeName)

Description copied from interface: ReadOnlyStoreRepository

Get one store by given name from repository.

Specified by:

getStore in interface ReadOnlyStoreRepository

Parameters:

storeName - name of wanted store.

Returns:

Store for given name.

getStoreOrThrow

public Store getStoreOrThrow(String storeName)
                      throws VeniceNoStoreException

Specified by:

getStoreOrThrow in interface ReadOnlyStoreRepository

Throws:

VeniceNoStoreException

hasStore

public boolean hasStore(String storeName)

Description copied from interface: ReadOnlyStoreRepository

Whether the store exists or not.

Specified by:

hasStore in interface ReadOnlyStoreRepository

Parameters:

storeName - store name

Returns:

getAllStores

public List<Store> getAllStores()

Description copied from interface: ReadOnlyStoreRepository

Get all stores in the current repository

Specified by:

getAllStores in interface ReadOnlyStoreRepository

Returns:

getTotalStoreReadQuota

public long getTotalStoreReadQuota()

Description copied from interface: ReadOnlyStoreRepository

Get total read quota of all stores.

Specified by:

getTotalStoreReadQuota in interface ReadOnlyStoreRepository

getBatchGetLimit

public int getBatchGetLimit(String storeName)

Description copied from interface: ReadOnlyStoreRepository

Get batch-get limit for the specified store

Specified by:

getBatchGetLimit in interface ReadOnlyStoreRepository

Returns:

isReadComputationEnabled

public boolean isReadComputationEnabled(String storeName)

Description copied from interface: ReadOnlyStoreRepository

Whether computation is enabled for the specified store.

Specified by:

isReadComputationEnabled in interface ReadOnlyStoreRepository

Parameters:

storeName - store name

Returns:

refresh

public void refresh()

Specified by:

refresh in interface VeniceResource

refreshOneStore

public Store refreshOneStore(String storeName)

Description copied from interface: ReadOnlyStoreRepository

Selective refresh operation which fetches one store from ZK

Specified by:

refreshOneStore in interface ReadOnlyStoreRepository

Parameters:

storeName - store name

Returns:

the newly refreshed store

clear

public void clear()

Specified by:

clear in interface VeniceResource

registerStoreDataChangedListener

public void registerStoreDataChangedListener(StoreDataChangedListener listener)

Description copied from interface: ReadOnlyStoreRepository

Register store data change listener.

Specified by:

registerStoreDataChangedListener in interface ReadOnlyStoreRepository

unregisterStoreDataChangedListener

public void unregisterStoreDataChangedListener(StoreDataChangedListener listener)

Description copied from interface: ReadOnlyStoreRepository

Unregister store data change listener.

Specified by:

unregisterStoreDataChangedListener in interface ReadOnlyStoreRepository

putStore

protected Store putStore(Store newStore)

removeStore

protected Store removeStore(String storeName)

getStoreZkPath

protected final String getStoreZkPath(String storeName)

getStoreFromZk

protected Store getStoreFromZk(String storeName)

getStoresFromZk

protected List<Store> getStoresFromZk()

HelixReadOnlyZKSharedSystemStoreRepository is overriding this function to filter out stores, which are not necessary to put a watch against during refresh(), and if this logic to refresh the zk store repository gets changed in the future, we need to update HelixReadOnlyZKSharedSystemStoreRepository accordingly.

getStoresFromZk

protected List<Store> getStoresFromZk(Collection<String> storeNames)

notifyStoreCreated

protected void notifyStoreCreated(Store store)

notifyStoreDeleted

protected void notifyStoreDeleted(Store store)

notifyStoreChanged

protected void notifyStoreChanged(Store store)