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 and Description
org.apache.flink.runtime.state.StateBackend	createStateBackend(FlinkPipelineOptions options)

Method Detail

createStateBackend

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