Constructor Detail

• NoopProcedureStore

  public NoopProcedureStore()

Method Detail

• start

  public void start(int numThreads)
             throws IOException

  Description copied from interface: ProcedureStore
  Start/Open the procedure store

  Throws:

  IOException

• stop

  public void stop(boolean abort)

  Description copied from interface: ProcedureStore
  Stop/Close the procedure store

  Parameters:

  abort - true if the stop is an abort

• recoverLease

  public void recoverLease()
                    throws IOException

  Description copied from interface: ProcedureStore
  Acquire the lease for the procedure store.

  Throws:

  IOException

• getNumThreads

  public int getNumThreads()

  Returns:

  the number of threads/slots passed to start()

• load

  public void load(ProcedureStore.ProcedureLoader loader)
            throws IOException

  Description copied from interface: ProcedureStore
  Load the Procedures in the store.

  Parameters:

  loader - the ProcedureLoader that will handle the store-load events

  Throws:

  IOException

• insert

  public void insert(Procedure proc,
            Procedure[] subprocs)

  Description copied from interface: ProcedureStore
  When a procedure is submitted to the executor insert(proc, null) will be called. 'proc' has a 'RUNNABLE' state and the initial information required to start up. When a procedure is executed and it returns children insert(proc, subprocs) will be called. 'proc' has a 'WAITING' state and an update state. 'subprocs' are the children in 'RUNNABLE' state with the initial information.

  Parameters:

  proc - the procedure to serialize and write to the store.

  subprocs - the newly created child of the proc.

• update

  public void update(Procedure proc)

  Description copied from interface: ProcedureStore
  The specified procedure was executed, and the new state should be written to the store.

  Parameters:

  proc - the procedure to serialize and write to the store.

• delete

  public void delete(long procId)

  Description copied from interface: ProcedureStore
  The specified procId was removed from the executor, due to completion, abort or failure. The store implementor should remove all the information about the specified procId.

  Parameters:

  procId - the ID of the procedure to remove.

• delete

  public void delete(Procedure proc,
            long[] subprocs)

  Description copied from interface: ProcedureStore
  The parent procedure completed. Update the state and mark all the child deleted.

  Parameters:

  proc - the parent procedure to serialize and write to the store.

  subprocs - the IDs of the sub-procedure to remove.