Hi Joe, my gut feeling is that a flatMap() is what you are looking for.
Best, Robert On Thu, May 28, 2020 at 7:21 PM Joe Malt <jm...@yelp.com> wrote: > 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 > > >
