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/
