To be clear, the main idea would be to define the "general framework" in terms of DataStream[Event], where `Event` would be a trait capturing the required commonalities. Within each specific application, one would work with different types of events but would ultimately perform a union in order to combine them in a DataStream[Event].
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
