Class StateFutureFactory<K>
- java.lang.Object
-
- org.apache.flink.runtime.asyncprocessing.StateFutureFactory<K>
-
public class StateFutureFactory<K> extends Object
An internal factory forInternalStateFuture
that build future with necessary context switch and wired with mailbox executor.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <OUT> InternalStateFuture<OUT>
create(RecordContext<K> context)
-
-
-
Method Detail
-
create
public <OUT> InternalStateFuture<OUT> create(RecordContext<K> context)
-
-