Package org.apache.flink.runtime.asyncprocessing

Class StateRequest<K,IN,OUT>

java.lang.Object

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

Type Parameters:

K - Type of partitioned key.

IN - Type of input of this request.

OUT - Type of value that request will return.

All Implemented Interfaces:

Serializable

public class StateRequest<K,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(org.apache.flink.api.common.state.v2.State state, StateRequestType type, IN payload, org.apache.flink.core.state.InternalStateFuture<OUT> stateFuture, RecordContext<K> context)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.core.state.InternalStateFuture<OUT>	getFuture()
IN	getPayload()
RecordContext<K>	getRecordContext()
StateRequestType	getRequestType()
org.apache.flink.api.common.state.v2.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
                    org.apache.flink.api.common.state.v2.State state,
                    StateRequestType type,
                    @Nullable
                    IN payload,
                    org.apache.flink.core.state.InternalStateFuture<OUT> stateFuture,
                    RecordContext<K> context)

Method Detail

getRequestType

public StateRequestType getRequestType()

getPayload

@Nullable
public IN getPayload()

getState

@Nullable
public org.apache.flink.api.common.state.v2.State getState()

getFuture

public org.apache.flink.core.state.InternalStateFuture<OUT> getFuture()

getRecordContext

public RecordContext<K> getRecordContext()