Just to be more clear on my goal - Im trying to enrich the incoming stream with some meaningful tags based on conditions from the event itself. So the input stream could be an event looks like: Class Car { int year; String modelName; }
i will have a config that are defining tags as: "NiceCar" -> "year > 2015 AND position("Luxury" in modelName) > 0" So ideally my output will be in the structure of Class TaggedEvent<Car> { Car origin; String[] tags; } -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/