K
- Type of partitioned key.IN
- Type of input of this request.OUT
- Type of value that request will return.public class StateRequest<K,IN,OUT> extends Object implements Serializable
Constructor and Description |
---|
StateRequest(State state,
StateRequestType type,
IN payload,
InternalStateFuture<OUT> stateFuture,
RecordContext<K> context) |
Modifier and Type | Method and Description |
---|---|
InternalStateFuture<OUT> |
getFuture() |
IN |
getPayload() |
RecordContext<K> |
getRecordContext() |
StateRequestType |
getRequestType() |
State |
getState() |
public StateRequest(@Nullable State state, StateRequestType type, @Nullable IN payload, InternalStateFuture<OUT> stateFuture, RecordContext<K> context)
public StateRequestType getRequestType()
public InternalStateFuture<OUT> getFuture()
public RecordContext<K> getRecordContext()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.