Package com.linkedin.venice.helix

Class HelixReadOnlyStoreRepositoryAdapter

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlyStoreRepositoryAdapter

All Implemented Interfaces:

ReadOnlyStoreRepository, VeniceResource

Direct Known Subclasses:

HelixReadWriteStoreRepositoryAdapter

public class HelixReadOnlyStoreRepositoryAdapter
extends Object
implements ReadOnlyStoreRepository

This repository provides an read only interface to access both system store and regular venice store.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	HelixReadOnlyStoreRepositoryAdapter.VeniceStoreDataChangedListener	StoreDataChangedListener to handle all the events from regularStoreDataChangedListener.

Constructor Summary

Constructors

Constructor	Description
HelixReadOnlyStoreRepositoryAdapter(HelixReadOnlyZKSharedSystemStoreRepository systemStoreRepository, ReadOnlyStoreRepository regularStoreRepository, String clusterName)

Method Summary

Modifier and Type	Method	Description
void	clear()
List<Store>	getAllStores()	So far, this function will return the regular Venice stores + the corresponding meta system store.
int	getBatchGetLimit(String storeName)	Get batch-get limit for the specified store
Store	getStore(String storeName)	Get one store by given name from repository.
Store	getStoreOrThrow(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.
void	refresh()
Store	refreshOneStore(String storeName)	Selective refresh operation which fetches one store from ZK
void	registerStoreDataChangedListener(StoreDataChangedListener listener)	Register store data change listener.
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

Constructor Details

HelixReadOnlyStoreRepositoryAdapter

public HelixReadOnlyStoreRepositoryAdapter(HelixReadOnlyZKSharedSystemStoreRepository systemStoreRepository,
 ReadOnlyStoreRepository regularStoreRepository,
 String clusterName)

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:

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

getAllStores

public List<Store> getAllStores()

So far, this function will return the regular Venice stores + the corresponding meta system store. TODO: if we want to support more system store types in this repo, we need to modify this function accordingly.

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

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

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

clear

public void clear()

Specified by:

clear in interface VeniceResource