Package com.linkedin.venice.helix

Class HelixReadOnlyStoreRepository

java.lang.Object

com.linkedin.venice.helix.CachedReadOnlyStoreRepository

com.linkedin.venice.helix.HelixReadOnlyStoreRepository

All Implemented Interfaces:

ReadOnlyStoreRepository, VeniceResource

Direct Known Subclasses:

HelixReadOnlyZKSharedSystemStoreRepository, SubscriptionBasedStoreRepository

public class HelixReadOnlyStoreRepository
extends CachedReadOnlyStoreRepository

Field Summary

Fields inherited from class com.linkedin.venice.helix.CachedReadOnlyStoreRepository

clusterLockManager, clusterName, clusterStoreRepositoryPath, STORE_REPOSITORY_PATH, storeMap, zkClient, zkDataAccessor

Constructor Summary

Constructors

Constructor	Description
HelixReadOnlyStoreRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer compositeSerializer, java.lang.String clusterName, int refreshAttemptsForZkReconnect, long refreshIntervalForZkReconnectInMs)

Method Summary

Modifier and Type	Method	Description
void	clear()
protected void	onRepositoryChanged(java.util.Collection<java.lang.String> newZkStoreNames)	HelixReadOnlyZKSharedSystemStoreRepository is overriding this function to filter out stores, which are not necessary to put a watch against, and if this logic to monitor the zk store repository gets changed in the future, we need to update HelixReadOnlyZKSharedSystemStoreRepository accordingly.
protected void	onStoreChanged(Store newStore)
protected Store	putStore(Store newStore)
void	refresh()
protected Store	removeStore(java.lang.String storeName)

Methods inherited from class com.linkedin.venice.helix.CachedReadOnlyStoreRepository

getAllStores, getBatchGetLimit, getStore, getStoreFromZk, getStoreOrThrow, getStoresFromZk, getStoresFromZk, getStoreZkPath, getTotalStoreReadQuota, hasStore, isReadComputationEnabled, notifyStoreChanged, notifyStoreCreated, notifyStoreDeleted, refreshOneStore, registerStoreDataChangedListener, unregisterStoreDataChangedListener

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

Constructor Detail

HelixReadOnlyStoreRepository

public HelixReadOnlyStoreRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
                                    HelixAdapterSerializer compositeSerializer,
                                    java.lang.String clusterName,
                                    int refreshAttemptsForZkReconnect,
                                    long refreshIntervalForZkReconnectInMs)

Method Detail

refresh

public void refresh()

Specified by:

refresh in interface VeniceResource

Overrides:

refresh in class CachedReadOnlyStoreRepository

clear

public void clear()

Specified by:

clear in interface VeniceResource

Overrides:

clear in class CachedReadOnlyStoreRepository

putStore

protected Store putStore(Store newStore)

Overrides:

putStore in class CachedReadOnlyStoreRepository

removeStore

protected Store removeStore(java.lang.String storeName)

Overrides:

removeStore in class CachedReadOnlyStoreRepository

onStoreChanged

protected void onStoreChanged(Store newStore)

onRepositoryChanged

protected void onRepositoryChanged(java.util.Collection<java.lang.String> newZkStoreNames)

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

Parameters:

newZkStoreNames -