| Interface | Description |
|---|---|
| LockStatus |
Interface to get status of a Lock without getting access to acquire/release lock.
|
| ProcedureExecutor.ProcedureExecutorListener | |
| ProcedureMetrics |
With this interface, the procedure framework provides means to collect following set of metrics
per procedure type for all procedures:
Count of submitted procedure instances
Time histogram for successfully completed procedure instances
Count of failed procedure instances
Please implement this interface to return appropriate metrics.
|
| ProcedureScheduler |
Keep track of the runnable procedures
|
| ProcedureStateSerializer | |
| RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote> |
Account of what procedures are running on remote node.
|
| RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote> |
Remote procedure reference.
|
| RSProcedureCallable |
A general interface for a sub procedure runs at RS side.
|
| Class | Description |
|---|---|
| AbstractProcedureScheduler | |
| FailedProcedure<TEnvironment> | |
| LockAndQueue |
Locking for mutual exclusion between procedures.
|
| LockedResource | |
| OnePhaseProcedure<TEnvironment> | |
| Procedure<TEnvironment> |
Base Procedure class responsible for Procedure Metadata; e.g.
|
| ProcedureDeque |
Type class.
|
| ProcedureEvent<T> |
Basic ProcedureEvent that contains an "object", which can be a description or a reference to the
resource to wait on, and a queue for suspended procedures.
|
| ProcedureExecutor<TEnvironment> |
Thread Pool that executes the submitted procedures.
|
| ProcedureExecutor.Testing |
Class with parameters describing how to fail/die when in testing-context.
|
| ProcedureInMemoryChore<TEnvironment> |
Special procedure used as a chore.
|
| ProcedureUtil |
Helper to convert to/from ProcedureProtos
|
| RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>> |
A procedure dispatcher that aggregates and sends after elapsed time or after we hit
count threshold.
|
| RemoteProcedureDispatcher.RemoteOperation |
Data structure with reference to remote operation.
|
| SequentialProcedure<TEnvironment> |
A SequentialProcedure describes one step in a procedure chain:
|
| SimpleProcedureScheduler |
Simple scheduler for procedures
|
| StateMachineProcedure<TEnvironment,TState> |
Procedure described by a series of steps.
|
| TwoPhaseProcedure<TEnvironment> |
| Enum | Description |
|---|---|
| LockedResourceType | |
| LockType | |
| Procedure.LockState | |
| StateMachineProcedure.Flow |
| Exception | Description |
|---|---|
| BadProcedureException | |
| FailedRemoteDispatchException |
Used internally signaling failed queue of a remote procedure
operation.
|
| NoNodeDispatchException |
Used internally signaling failed queue of a remote procedure operation.
|
| NoServerDispatchException |
Used internally signaling failed queue of a remote procedure operation.
|
| NullTargetServerDispatchException |
Used internally signaling failed queue of a remote procedure operation.
|
| ProcedureAbortedException |
Thrown when a procedure is aborted
|
| ProcedureException | |
| ProcedureSuspendedException | |
| ProcedureYieldException | |
| RemoteProcedureException |
A RemoteProcedureException is an exception from another thread or process.
|
Copyright © 2007–2019 Cloudera. All rights reserved.