Package com.linkedin.venice.controller

Interface ExecutionIdAccessor

All Known Implementing Classes:
InMemoryExecutionIdAccessor, ZkExecutionIdAccessor
public interface ExecutionIdAccessor
Accessor user to get/update the last execution id and the generated id from a storage.

  • Method Details

    • getLastSucceededExecutionId

      Long getLastSucceededExecutionId(String clusterName)
      Get the id for the last succeed operation in the given cluster.

    • updateLastSucceededExecutionId

      void updateLastSucceededExecutionId(String clusterName, Long lastSucceedExecutionId)
      Update the id of the last succeed operation in the given cluster.

    • getLastSucceededExecutionIdMap

      Map<String,Long> getLastSucceededExecutionIdMap(String clusterName)
      Get the execution id map that contains the last succeeded operation in the given cluster for each store.

    • updateLastSucceededExecutionIdMap

      void updateLastSucceededExecutionIdMap(String clusterName, String storeName, Long lastSucceededExecutionId)
      Update the execution id map that contains the last succeeded operation in the given cluster for each store.

    • getLastGeneratedExecutionId

      Long getLastGeneratedExecutionId(String clusterName)
      Get the last id which is generated by execution tracker in the give cluster.

    • updateLastGeneratedExecutionId

      void updateLastGeneratedExecutionId(String clusterName, Long lastGeneratedExecutionId)
      Update the last id which is generated by execution tracker in the given cluster.

    • incrementAndGetExecutionId

      Long incrementAndGetExecutionId(String clusterName)
      Read the current value from ZK and try to increment the value by 1 and write it back to ZK.
      Returns:
      updated execution id.