Hey,

I am using Beam with Flink and want to set `stateBacked` via pipeline
options available here
https://github.com/apache/beam/blob/master/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineOptions.java#L120

The property is an abstract class. I was not able to figure out so far what
to pass to command line for initialization. How to provide such complex
abstract type? Is it possible?
.. I am trying to use rocksdb backend with incremental checkpointing ..

Reply via email to