Hi all,
is it possible that Custom Window Trigger (extending Trigger class) will
also implement CheckpointedFunction?
In my custom Trigger I have a complicated logic executed in
Trigger::onElement method.
Currently I'm using a triggerctx.getPartitionedState to do all reads and
writes for data management.
However I was wondering if it is possible to implement this interface, keep
state in Trogger's local Java variables and persist it into StateBeckend
only on snapshot.
I'm using RocksDB state backend and Flink 1.9.2
--
Sent from:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Locked
