Package org.apache.flink.runtime.asyncprocessing

Interface StateRequestHandler

All Known Implementing Classes:

AsyncExecutionController

@Internal
public interface StateRequestHandler

The handler which can process StateRequest.

Method Summary

Modifier and Type	Method	Description
<IN,OUT> InternalStateFuture<OUT>	handleRequest(State state, StateRequestType type, IN payload)	Submit a StateRequest to this StateRequestHandler.
<IN,OUT> OUT	handleRequestSync(State state, StateRequestType type, IN payload)	Submit a StateRequest to this StateRequestHandler, and wait for the response synchronously.
<N> void	setCurrentNamespaceForState(InternalPartitionedState<N> state, N namespace)	Set current namespace for a state.

Method Detail

handleRequest

<IN,OUT> InternalStateFuture<OUT> handleRequest(@Nullable
                                                      State state,
                                                      StateRequestType type,
                                                      @Nullable
                                                      IN payload)

Submit a StateRequest to this StateRequestHandler.

Parameters:

state - the state to request. Could be null if the type is StateRequestType.SYNC_POINT.

type - the type of this request.

payload - the payload input for this request.

Returns:

the state future.

handleRequestSync

<IN,OUT> OUT handleRequestSync(State state,
                                     StateRequestType type,
                                     @Nullable
                                     IN payload)

Submit a StateRequest to this StateRequestHandler, and wait for the response synchronously.

Parameters:

state - the state to request.

type - the type of this request.

payload - the payload input for this request.

Returns:

the state future.

setCurrentNamespaceForState

<N> void setCurrentNamespaceForState(@Nonnull
                                     InternalPartitionedState<N> state,
                                     N namespace)

Set current namespace for a state. See InternalPartitionedState.setCurrentNamespace(Object).