Package org.apache.flink.streaming.api.operators

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

  • Enclosing class:
    StreamTaskStateInitializerImpl
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    @FunctionalInterface
protected static interface StreamTaskStateInitializerImpl.KeyedStateBackendCreator<K,​R extends org.apache.flink.util.Disposable & Closeable>
    Functional interface to create the keyed state backend.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      R create​(org.apache.flink.runtime.state.StateBackend stateBackend, org.apache.flink.runtime.state.StateBackend.KeyedStateBackendParameters<K> keyedStateBackendParameters)
      Create the keyed state backend.

    • Method Detail

      • 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.
        Throws:
        Exception