Package com.linkedin.venice.helix

Class HelixStoreGraveyard

java.lang.Object

com.linkedin.venice.helix.HelixStoreGraveyard

All Implemented Interfaces:

StoreGraveyard

public class HelixStoreGraveyard
extends Object
implements StoreGraveyard

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.helix.manager.zk.ZkBaseDataAccessor<Store>	dataAccessor
static final String	STORE_GRAVEYARD_PATH

Constructor Summary

Constructors

Constructor	Description
HelixStoreGraveyard(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, Collection<String> clusterNames)
HelixStoreGraveyard(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, Collection<String> clusterNames, VeniceSerializer<Store> storeSerializer)

Method Summary

Modifier and Type	Method	Description
int	getLargestUsedRTVersionNumber(String storeName)	Retrieve the largest used version number for the real time topic by the given store name from graveyard.
int	getLargestUsedVersionNumber(String storeName)	Retrieve the largest used version number by the given store name from graveyard.
Store	getStoreFromGraveyard(String clusterName, String storeName, org.apache.zookeeper.data.Stat stat)	Get store from the graveyard in the specified cluster.
List<String>	listStoreNamesFromGraveyard(String clusterName)	List store names from graveyard in the specified cluster.
void	putStoreIntoGraveyard(String clusterName, Store store)	Put the given store into graveyard.
void	removeStoreFromGraveyard(String clusterName, String storeName)	Remove the given store from graveyard in the specified cluster.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

STORE_GRAVEYARD_PATH

public static final String STORE_GRAVEYARD_PATH

See Also:

• Constant Field Values

dataAccessor

protected org.apache.helix.manager.zk.ZkBaseDataAccessor<Store> dataAccessor

Constructor Details

HelixStoreGraveyard

public HelixStoreGraveyard(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 Collection<String> clusterNames)

HelixStoreGraveyard

public HelixStoreGraveyard(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 Collection<String> clusterNames,
 VeniceSerializer<Store> storeSerializer)

Method Details

getLargestUsedRTVersionNumber

public int getLargestUsedRTVersionNumber(String storeName)

Description copied from interface: StoreGraveyard

Retrieve the largest used version number for the real time topic by the given store name from graveyard. Return 0 if the store does not exist in the graveyard, which is the default value we used for the new store.

Specified by:

getLargestUsedRTVersionNumber in interface StoreGraveyard

getLargestUsedVersionNumber

public int getLargestUsedVersionNumber(String storeName)

Description copied from interface: StoreGraveyard

Retrieve the largest used version number by the given store name from graveyard. Return 0 if the store does not exist in the graveyard, which is the default value we used for the new store.

Specified by:

getLargestUsedVersionNumber in interface StoreGraveyard

putStoreIntoGraveyard

public void putStoreIntoGraveyard(String clusterName,
 Store store)

Description copied from interface: StoreGraveyard

Put the given store into graveyard. If the store has already existed in the graveyard, update it by this given store.

Specified by:

putStoreIntoGraveyard in interface StoreGraveyard

getStoreFromGraveyard

public Store getStoreFromGraveyard(String clusterName,
 String storeName,
 org.apache.zookeeper.data.Stat stat)

Description copied from interface: StoreGraveyard

Get store from the graveyard in the specified cluster.

Specified by:

getStoreFromGraveyard in interface StoreGraveyard

removeStoreFromGraveyard

public void removeStoreFromGraveyard(String clusterName,
 String storeName)

Description copied from interface: StoreGraveyard

Remove the given store from graveyard in the specified cluster.

Specified by:

removeStoreFromGraveyard in interface StoreGraveyard

listStoreNamesFromGraveyard

public List<String> listStoreNamesFromGraveyard(String clusterName)

Description copied from interface: StoreGraveyard

List store names from graveyard in the specified cluster.

Specified by:

listStoreNamesFromGraveyard in interface StoreGraveyard