Package com.linkedin.venice.controller

Interface ExecutionIdAccessor

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      java.lang.Long getLastGeneratedExecutionId​(java.lang.String clusterName)
      Get the last id which is generated by execution tracker in the give cluster.
      java.lang.Long getLastSucceededExecutionId​(java.lang.String clusterName)
      Get the id for the last succeed operation in the given cluster.
      java.util.Map<java.lang.String,​java.lang.Long> getLastSucceededExecutionIdMap​(java.lang.String clusterName)
      Get the execution id map that contains the last succeeded operation in the given cluster for each store.
      java.lang.Long incrementAndGetExecutionId​(java.lang.String clusterName)
      Read the current value from ZK and try to increment the value by 1 and write it back to ZK.
      void updateLastGeneratedExecutionId​(java.lang.String clusterName, java.lang.Long lastGeneratedExecutionId)
      Update the last id which is generated by execution tracker in the given cluster.
      void updateLastSucceededExecutionId​(java.lang.String clusterName, java.lang.Long lastSucceedExecutionId)
      Update the id of the last succeed operation in the given cluster.
      void updateLastSucceededExecutionIdMap​(java.lang.String clusterName, java.lang.String storeName, java.lang.Long lastSucceededExecutionId)
      Update the execution id map that contains the last succeeded operation in the given cluster for each store.

    • Method Detail

      • getLastSucceededExecutionId

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

      • updateLastSucceededExecutionId

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

      • getLastSucceededExecutionIdMap

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

      • updateLastSucceededExecutionIdMap

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

      • getLastGeneratedExecutionId

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

      • updateLastGeneratedExecutionId

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

      • incrementAndGetExecutionId

        java.lang.Long incrementAndGetExecutionId​(java.lang.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.