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

Pass complex type to FlinkPipelineOptions


I am using Beam with Flink and want to set `stateBacked` via pipeline options available here

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