Package org.apache.flink.core.state
-
Interface Summary Interface Description InternalStateFuture<T> The Internal definition ofStateFuture, add some method that will be used by framework.StateFutureImpl.AsyncFrameworkExceptionHandler Handle exceptions thrown by async state callback framework.StateFutureImpl.CallbackRunner The entry for a state future to submit task to mailbox. -
Class Summary Class Description CompletedStateFuture<T> AStateFuturethat has already been completed when it is created.StateFutureImpl<T> The default implementation ofStateFuture.StateFutureUtils A collection of utilities that expand the usage ofStateFuture.