git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Pass complex type to FlinkPipelineOptions


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 ..