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 Details

    • HelixPartitionStatusAccessor

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

  • Method Details

    • updateReplicaStatus

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

    • updateHybridQuotaReplicaStatus

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

    • deleteReplicaStatus

      public void deleteReplicaStatus(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(String topic, int partitionId)

    • getHybridQuotaReplicaStatus

      public HybridStoreQuotaStatus getHybridQuotaReplicaStatus(String topic, int partitionId)

    • getAllReplicaStatus

      public Map<Integer,ExecutionStatus> getAllReplicaStatus(String topic)