Package com.linkedin.venice.helix

Class SubscriptionBasedStoreRepository

java.lang.Object

com.linkedin.venice.helix.CachedReadOnlyStoreRepository

com.linkedin.venice.helix.HelixReadOnlyStoreRepository

com.linkedin.venice.helix.SubscriptionBasedStoreRepository

All Implemented Interfaces:

ReadOnlyStoreRepository, SubscriptionBasedReadOnlyStoreRepository, VeniceResource

public class SubscriptionBasedStoreRepository
extends HelixReadOnlyStoreRepository
implements SubscriptionBasedReadOnlyStoreRepository

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
SubscriptionBasedStoreRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer compositeSerializer, String clusterName)

Method Summary

Modifier and Type	Method	Description
protected Store	putStore(Store newStore)
void	subscribe(String storeName)
void	unsubscribe(String storeName)

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

clear, onRepositoryChanged, onStoreChanged, refresh, removeStore

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

getAllStores, getBatchGetLimit, getStore, getStoreOrThrow, getTotalStoreReadQuota, hasStore, isReadComputationEnabled, refreshOneStore, registerStoreDataChangedListener, unregisterStoreDataChangedListener, waitVersion, waitVersion

Methods inherited from interface com.linkedin.venice.VeniceResource

clear, refresh

Constructor Details

SubscriptionBasedStoreRepository

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

Method Details

subscribe

public void subscribe(String storeName)
               throws InterruptedException

Specified by:

subscribe in interface SubscriptionBasedReadOnlyStoreRepository

Throws:

InterruptedException

unsubscribe

public void unsubscribe(String storeName)

Specified by:

unsubscribe in interface SubscriptionBasedReadOnlyStoreRepository

putStore

protected Store putStore(Store newStore)

Overrides:

putStore in class HelixReadOnlyStoreRepository