Package com.linkedin.venice.helix

Class HelixStoreVersionAccessor

java.lang.Object

com.linkedin.venice.helix.HelixStoreVersionAccessor

public class HelixStoreVersionAccessor
extends Object

Accessor for individual version znodes that live as children of a store znode: /<cluster>/Stores/<storeName>/versions/<versionNumber>. The accessor is the controller-side write path and the reader-side read path for per-version data. The legacy "embedded versions list inside the store JSON" representation is handled by the store repository; this accessor deals only with the new layout.

Constructor Summary

Constructors

Constructor	Description
HelixStoreVersionAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, String clusterName)
HelixStoreVersionAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, String clusterName, int refreshAttemptsForZkReconnect)

Method Summary

Modifier and Type	Method	Description
Version	getVersion(String storeName, int versionNumber)
List<String>	getVersionNumbersForStore(String storeName)
String	getVersionsContainerPath(String storeName)
List<Version>	getVersionsForStore(String storeName)
String	getVersionZkPath(String storeName, int versionNumber)
boolean	hasVersionsContainer(String storeName)
void	putVersion(String storeName, Version version)
void	removeAllVersionsForStore(String storeName)
void	removeVersion(String storeName, int versionNumber)

Methods inherited from class java.lang.Object

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

Constructor Details

HelixStoreVersionAccessor

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

HelixStoreVersionAccessor

public HelixStoreVersionAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 String clusterName,
 int refreshAttemptsForZkReconnect)

Method Details

getVersionsContainerPath

public String getVersionsContainerPath(String storeName)

getVersionZkPath

public String getVersionZkPath(String storeName,
 int versionNumber)

hasVersionsContainer

public boolean hasVersionsContainer(String storeName)

getVersion

public Version getVersion(String storeName,
 int versionNumber)

getVersionsForStore

public List<Version> getVersionsForStore(String storeName)

getVersionNumbersForStore

public List<String> getVersionNumbersForStore(String storeName)

putVersion

public void putVersion(String storeName,
 Version version)

removeVersion

public void removeVersion(String storeName,
 int versionNumber)

removeAllVersionsForStore

public void removeAllVersionsForStore(String storeName)