Package org.apache.flink.runtime.asyncprocessing

Class StateRequest<K,N,IN,OUT>

java.lang.Object

org.apache.flink.runtime.asyncprocessing.StateRequest<K,N,IN,OUT>

Type Parameters:

K - Type of partitioned key.

IN - Type of input of this request.

N - Type of namespace.

OUT - Type of value that request will return.

All Implemented Interfaces:

Serializable

public class StateRequest<K,N,IN,OUT>
extends Object
implements Serializable

A request encapsulates the necessary data to perform a state request.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StateRequest(State state, StateRequestType type, IN payload, InternalStateFuture<OUT> stateFuture, RecordContext<K> context)

Method Summary

Modifier and Type	Method	Description
InternalStateFuture<OUT>	getFuture()
N	getNamespace()
IN	getPayload()
RecordContext<K>	getRecordContext()
StateRequestType	getRequestType()
State	getState()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StateRequest

public StateRequest(@Nullable
                    State state,
                    StateRequestType type,
                    @Nullable
                    IN payload,
                    InternalStateFuture<OUT> stateFuture,
                    RecordContext<K> context)

Method Detail

getRequestType

public StateRequestType getRequestType()

getPayload

@Nullable
public IN getPayload()

getState

@Nullable
public State getState()

getFuture

public InternalStateFuture<OUT> getFuture()

getRecordContext

public RecordContext<K> getRecordContext()

getNamespace

@Nullable
public N getNamespace()