Package com.linkedin.venice.helix

Class HelixPartitionStatusAccessor

java.lang.Object

com.linkedin.venice.helix.HelixPartitionStateAccessor

com.linkedin.venice.helix.HelixPartitionStatusAccessor

public class HelixPartitionStatusAccessor
extends HelixPartitionStateAccessor

A class for accessing partition offline push and hybrid quota status in Helix customized state (per Helix instance) on Zookeeper

Constructor Summary

Constructors

Constructor	Description
HelixPartitionStatusAccessor(org.apache.helix.HelixManager helixManager, java.lang.String instanceId, boolean isHelixHybridStoreQuotaEnabled)

Method Summary

Modifier and Type	Method	Description
void	deleteReplicaStatus(java.lang.String topic, int partitionId)	When a replica is gone from an instance due to partition movement or resource drop, we need to call this delete function to explicitly delete the customized state for that replica.
java.util.Map<java.lang.Integer,ExecutionStatus>	getAllReplicaStatus(java.lang.String topic)
HybridStoreQuotaStatus	getHybridQuotaReplicaStatus(java.lang.String topic, int partitionId)
ExecutionStatus	getReplicaStatus(java.lang.String topic, int partitionId)
void	updateHybridQuotaReplicaStatus(java.lang.String topic, int partitionId, HybridStoreQuotaStatus status)
void	updateReplicaStatus(java.lang.String topic, int partitionId, ExecutionStatus status)

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

deleteReplicaStatus, getAllReplicaStatus, getReplicaStatus, setCustomizedStateProvider, updateReplicaStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

HelixPartitionStatusAccessor

public HelixPartitionStatusAccessor(org.apache.helix.HelixManager helixManager,
                                    java.lang.String instanceId,
                                    boolean isHelixHybridStoreQuotaEnabled)

Method Detail

updateReplicaStatus

public void updateReplicaStatus(java.lang.String topic,
                                int partitionId,
                                ExecutionStatus status)

updateHybridQuotaReplicaStatus

public void updateHybridQuotaReplicaStatus(java.lang.String topic,
                                           int partitionId,
                                           HybridStoreQuotaStatus status)

deleteReplicaStatus

public void deleteReplicaStatus(java.lang.String topic,
                                int partitionId)

When a replica is gone from an instance due to partition movement or resource drop, we need to call this delete function to explicitly delete the customized state for that replica. Otherwise, customized state will still stay there. Usually this should happen during state transition. If the partition state is the last partition state in the resource znode, the znode will also be deleted.

getReplicaStatus

public ExecutionStatus getReplicaStatus(java.lang.String topic,
                                        int partitionId)

getHybridQuotaReplicaStatus

public HybridStoreQuotaStatus getHybridQuotaReplicaStatus(java.lang.String topic,
                                                          int partitionId)

getAllReplicaStatus

public java.util.Map<java.lang.Integer,ExecutionStatus> getAllReplicaStatus(java.lang.String topic)