Hi, I'm working on a custom TimestampAssigner which will do different things depending on the value of the extracted timestamp. One of the actions I want to take is to drop messages entirely if their timestamp meets certain criteria.
Of course there's no direct way to do this in the TimestampAssigner, but I'd like to keep this logic as close to the TimestampAssigner as possible since this is going to be a pluggable component used in a bunch of different Flink apps. What would be the best way to implement this? Thanks, Joe
