Hi guys, I would ask to you how could I create triggers in Flink. I would like to perform some operations on a dataset and according to some conditions, based on an attribute of a Pojo class or Tuple, execute some triggers. I mean, starting collecting other datasources' data and performing operations over them.
An Example. I have a dataset of Pojo class Person. My trigger activation condition is (number of italian people > 100). If so, I collect another datasource and I execute operations over it. Do you think is that possible in Flink? Thanks, Giacomo
