org.apache.flink.streaming.api.operators

接口 StreamTaskStateInitializerImpl.KeyedStateBackendCreator<K,R extends org.apache.flink.util.Disposable & Closeable>

封闭类:

StreamTaskStateInitializerImpl

函数接口:

这是一个函数接口, 因此可用作 lambda 表达式或方法引用的赋值目标。

@FunctionalInterface
protected static interface StreamTaskStateInitializerImpl.KeyedStateBackendCreator<K,R extends org.apache.flink.util.Disposable & Closeable>

Functional interface to create the keyed state backend.

方法概要

限定符和类型	方法和说明
R	create(org.apache.flink.runtime.state.StateBackend stateBackend, org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K> keyedStateBackendParameters) Create the keyed state backend.

方法详细资料

create

R create(org.apache.flink.runtime.state.StateBackend stateBackend,
         org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K> keyedStateBackendParameters)
  throws Exception

Create the keyed state backend.

抛出:

Exception