Package org.apache.flink.core.state

Interface InternalStateFuture<T>

  • All Superinterfaces:
    org.apache.flink.api.common.state.v2.StateFuture<T>
    All Known Implementing Classes:
    CompletedStateFuture, StateFutureImpl
    @Internal
public interface InternalStateFuture<T>
extends org.apache.flink.api.common.state.v2.StateFuture<T>
    The Internal definition of StateFuture, add some method that will be used by framework.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void complete​(T result)
      Complete this future.
      void completeExceptionally​(String message, Throwable ex)
      Fail this future and pass the given exception to the runtime.
      void thenSyncAccept​(org.apache.flink.util.function.ThrowingConsumer<? super T,​? extends Exception> action)
      Accept the action in the same thread with the one of complete (or current thread if it has been completed).

      • Methods inherited from interface org.apache.flink.api.common.state.v2.StateFuture

        thenAccept, thenApply, thenCombine, thenCompose

    • Method Detail

      • complete

        void complete​(T result)
        Complete this future.

      • completeExceptionally

        void completeExceptionally​(String message,
                           Throwable ex)
        Fail this future and pass the given exception to the runtime.
        Parameters:
        message - the description of this exception
        ex - the exception

      • thenSyncAccept

        void thenSyncAccept​(org.apache.flink.util.function.ThrowingConsumer<? super T,​? extends Exception> action)
        Accept the action in the same thread with the one of complete (or current thread if it has been completed).
        Parameters:
        action - the action to perform.