Package org.apache.flink.runtime.asyncprocessing

Interface Summary

Interface	Description
AsyncExecutionController.SwitchContextListener<K>	A listener listens the key context switch.
RecordContext.DisposerRunner
StateExecutor	Executor for executing batch StateRequests.
StateRequestContainer	A container which is used to hold StateRequests.
StateRequestHandler	The handler which can process StateRequest.

Class Summary

Class	Description
AbstractStateIterator<T>	A StateIterator implementation to facilitate async data load of iterator.
AsyncExecutionController<K>	The Async Execution Controller (AEC) receives processing requests from operators, and put them into execution according to some strategies.
BatchCallbackRunner	A StateFutureImpl.CallbackRunner that put one mail in MailboxExecutor but run multiple callbacks within one mail.
ContextStateFutureImpl<T>	A state future that holds the RecordContext and maintains the reference count of it.
EpochManager	Epoch manager segments inputs into distinct epochs, marked by the arrival of non-records(e.g.
EpochManager.Epoch	All inputs are segment into distinct epochs, marked by the arrival of non-record inputs.
KeyAccountingUnit<K>	Key accounting unit holds the current in-flight key and tracks the corresponding ongoing records, which is used to preserve the ordering of independent chained StateFuture.
RecordContext<K>	A context that preserves the necessary variables required by each operation, all operations for one record will share the same element context.
ReferenceCounted<ReleaseHelper>	An object that can be reference counted, the internal resource would be released when the reference count reaches zero.
StateFutureFactory<K>	An internal factory for InternalStateFuture that build future with necessary context switch and wired with mailbox executor.
StateRequest<K,N,IN,OUT>	A request encapsulates the necessary data to perform a state request.
StateRequestBuffer<K>	A buffer to hold state requests to execute state requests in batch, which can only be manipulated within task thread.

Enum Summary

Enum	Description
EpochManager.ParallelMode	This enum defines whether parallel execution between epochs is allowed.
StateRequestType	The type of processing request for State from **users' perspective**.

Exception Summary

Exception	Description
AsyncStateException	An exception for wrapping exceptions that are thrown by StateFuture callback framework.