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
static final long	STORE_NOT_IN_GRAVEYARD	Constant indicating that a store does not exist in the graveyard.

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.
long	getStoreDeletedTime(String clusterName, String storeName)	Get the deletion time of a store in the 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

STORE_NOT_IN_GRAVEYARD

public static final long STORE_NOT_IN_GRAVEYARD

Constant indicating that a store does not exist in the graveyard.

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

getStoreDeletedTime

public long getStoreDeletedTime(String clusterName,
 String storeName)

Get the deletion time of a store in the graveyard. This returns the modification time of the ZNode, which represents when the store was last put into the graveyard or when the graveyard entry was last updated. Note that this may not be the original deletion time if the store has been deleted multiple times or the graveyard entry has been modified.

Specified by:

getStoreDeletedTime in interface StoreGraveyard

Parameters:

clusterName - the cluster name

storeName - the store name

Returns:

the ZNode modification time in milliseconds since epoch, or STORE_NOT_IN_GRAVEYARD if the store doesn't exist in graveyard

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