Interface StateFactory<T extends org.apache.flink.runtime.scheduler.adaptive.State>

  • Type Parameters:
    T - Type of the state.

    public interface StateFactory<T extends org.apache.flink.runtime.scheduler.adaptive.State>
    Factory for creating adaptive scheduler state instances.
    • Method Detail

      • getStateClass

        Class<T> getStateClass()
      • getState

        T getState()