Package org.apache.hadoop.hbase.procedure2.store

Interface ProcedureStore.ProcedureStoreListener

Enclosing interface:
ProcedureStore
public static interface ProcedureStore.ProcedureStoreListener
Store listener interface.

The main process should register a listener and respond to the store events.

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    abortProcess()
    triggered when the store is not able to write out data.
    default void
    forceUpdate(long[] procIds)
    Suggest that the upper layer should update the state of some procedures.
    default void
    postSync()
    triggered when the store sync is completed.

  • Method Details

    • postSync

      default void postSync()
      triggered when the store sync is completed.

    • abortProcess

      default void abortProcess()
      triggered when the store is not able to write out data. the main process should abort.

    • forceUpdate

      default void forceUpdate(long[] procIds)
      Suggest that the upper layer should update the state of some procedures. Ignore this call will not effect correctness but performance.

      For a WAL based ProcedureStore implementation, if all the procedures stored in a WAL file have been deleted, or updated later in another WAL file, then we can delete the WAL file. If there are old procedures in a WAL file which are never deleted or updated, then we can not delete the WAL file and this will cause we hold lots of WAL file and slow down the master restarts. So here we introduce this method to tell the upper layer that please update the states of these procedures so that we can delete the old WAL file.

      Parameters:
      procIds - the id for the procedures