FlinkStateBackendFactory

[Jin Yi]

Hi Experts,

I am running Beam application with Flink Runner. I would like to set State
Backend to be FsStateBackend instead of MemoryStateBackend.

in FlinkPipelineOptions.java

I should be able to call setStateBackendFactory(), but I did not find any
provided implementations for FlinkStateBackendFactory interface, so that
means I have to implement my own?

Thanks a lot!
Eleanore

/**
 * State backend to store Beam's state during computation. Note: Only
applicable when executing in
 * streaming mode.
 */
@Description(
    "Sets the state backend factory to use in streaming mode. "
        + "Defaults to the flink cluster's state.backend configuration.")
Class<? extends FlinkStateBackendFactory> getStateBackendFactory();

void setStateBackendFactory(Class<? extends FlinkStateBackendFactory>
stateBackendFactory);