Package com.linkedin.venice.helix

Class HelixPartitionStateAccessor

java.lang.Object

com.linkedin.venice.helix.HelixPartitionStateAccessor

Direct Known Subclasses:

HelixPartitionStatusAccessor

public abstract class HelixPartitionStateAccessor
extends Object

A parent class to access Helix customized partition state, which is different from the states defined in the state model. The partition state is stored on Zookeeper. This class provides the way to read/write the state. Note this class is only an accessor but not a repository so it will not cache anything in local memory. In other words it's stateless and Thread-Safe. The data structure on ZK would be: /VeniceClusterName/INSTANCES/instanceName/CUSTOMIZEDSTATE/$topic -> customized state for $topic

Constructor Summary

Constructors

Constructor	Description
HelixPartitionStateAccessor(org.apache.helix.HelixManager helixManager, String instanceId)

Method Summary

Modifier and Type	Method	Description
void	deleteReplicaStatus(HelixPartitionState stateType, String topic, String partitionName)
Map<String,String>	getAllReplicaStatus(HelixPartitionState stateType, String topic)
String	getReplicaStatus(HelixPartitionState stateType, String topic, String partitionName)
void	setCustomizedStateProvider(org.apache.helix.customizedstate.CustomizedStateProvider customizedStateProvider)	Only used in test now
void	updateReplicaStatus(HelixPartitionState stateType, String topic, String partitionName, String status)

Methods inherited from class java.lang.Object

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

Constructor Details

HelixPartitionStateAccessor

public HelixPartitionStateAccessor(org.apache.helix.HelixManager helixManager,
 String instanceId)

Method Details

updateReplicaStatus

public void updateReplicaStatus(HelixPartitionState stateType,
 String topic,
 String partitionName,
 String status)

deleteReplicaStatus

public void deleteReplicaStatus(HelixPartitionState stateType,
 String topic,
 String partitionName)

getReplicaStatus

public String getReplicaStatus(HelixPartitionState stateType,
 String topic,
 String partitionName)

getAllReplicaStatus

public Map<String,String> getAllReplicaStatus(HelixPartitionState stateType,
 String topic)

setCustomizedStateProvider

public void setCustomizedStateProvider(org.apache.helix.customizedstate.CustomizedStateProvider customizedStateProvider)

Only used in test now