Hello Congxian,
Thanks for your response,
Don't you have an example with an Operator extending the
AbstractUdfStreamOperator?
Using the context.getRawKeyedStateInputs() (& output to snapshots)
TimeService is reimplementing the whole stuff :/
--
Bastien DINE
Data Architect /
Hi
Currently, I think you can ref the implementation of timerservice[1]
which used the raw keyed state, the snapshot happens in
AbstractStreamOperator#snapshotState(), for using Raw State you need to
implement a new operator[2]. There is an issue wants to give some example
for raw state[2]
[1]
Hello everyone,
I would like to know if anybody has a working example on how to declare a
keyed raw state ( in my case a keyedprocessoperator) and how to use it in
my UDF (keyedprocessfunction)?
Basicaly we have a huge problem with a ValueState w Rocksdb, getting
serialized for every element (
