Package com.linkedin.venice.helix

Class HelixReadWriteStoreRepositoryAdapter

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlyStoreRepositoryAdapter

com.linkedin.venice.helix.HelixReadWriteStoreRepositoryAdapter

All Implemented Interfaces:

ReadOnlyStoreRepository, ReadWriteStoreRepository, VeniceResource

public class HelixReadWriteStoreRepositoryAdapter
extends HelixReadOnlyStoreRepositoryAdapter
implements ReadWriteStoreRepository

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

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.helix.HelixReadOnlyStoreRepositoryAdapter

HelixReadOnlyStoreRepositoryAdapter.VeniceStoreDataChangedListener

Constructor Summary

Constructors

Constructor	Description
HelixReadWriteStoreRepositoryAdapter(HelixReadOnlyZKSharedSystemStoreRepository systemStoreRepository, ReadWriteStoreRepository regularStoreRepository, String clusterName)

Method Summary

Modifier and Type	Method	Description
void	addStore(Store store)	This function only be used to add regular venice store, and the system store is bundled with regular venice store.
void	deleteStore(String name)	This function only be used to delete regular venice store, and the system store is bundled with regular venice store.
Store	getStore(String storeName)	Get one store by given name from repository.
void	updateStore(Store store)	Update store in repository.

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

clear, getAllStores, getBatchGetLimit, getStoreOrThrow, getTotalStoreReadQuota, hasStore, isReadComputationEnabled, refresh, 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, getStoreOrThrow, getTotalStoreReadQuota, hasStore, isReadComputationEnabled, refreshOneStore, registerStoreDataChangedListener, unregisterStoreDataChangedListener, waitVersion, waitVersion

Methods inherited from interface com.linkedin.venice.VeniceResource

clear, refresh

Constructor Details

HelixReadWriteStoreRepositoryAdapter

public HelixReadWriteStoreRepositoryAdapter(HelixReadOnlyZKSharedSystemStoreRepository systemStoreRepository,
 ReadWriteStoreRepository 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

Overrides:

getStore in class HelixReadOnlyStoreRepositoryAdapter

Parameters:

storeName - name of wanted store.

Returns:

Store for given name.

updateStore

public void updateStore(Store store)

Description copied from interface: ReadWriteStoreRepository

Update store in repository.

Specified by:

updateStore in interface ReadWriteStoreRepository

Parameters:

store - store need to be udpated.

deleteStore

public void deleteStore(String name)

This function only be used to delete regular venice store, and the system store is bundled with regular venice store.

Specified by:

deleteStore in interface ReadWriteStoreRepository

Parameters:

name - name of wantted store.

addStore

public void addStore(Store store)

This function only be used to add regular venice store, and the system store is bundled with regular venice store.

Specified by:

addStore in interface ReadWriteStoreRepository

Parameters:

store - store need to be added.