Hi ,
I was trying to do checkpointing while using siddhi as the CEP engine
running on flink. While using siddhi windowing , it uses an internal state to
aggregated or perform operation on a bucket of events pertaining to a specific
time window. But what i am not sure is how can that state be mapped to Flinks
internal state so that i can use flink checkpointing to safeguard the internal
state of the siddhi operators in the face of failure.
Any help or pointer for this will be of great help to me.Thanks in advance.
Dipanjan -
