Package org.apache.beam.runners.flink

Interface FlinkStateBackendFactory

public interface FlinkStateBackendFactory
Constructs a StateBackend to use from flink pipeline options.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.runtime.state.StateBackend
    createStateBackend(FlinkPipelineOptions options)
     

  • Method Details

    • createStateBackend

      org.apache.flink.runtime.state.StateBackend createStateBackend(FlinkPipelineOptions options)