I should add: the operators determine how to handle each message by inspecting the message's SCHEMA_ID field (every message has a SCHEMA_ID as its first field).
-- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Are-heterogeneous-DataStreams-possible-tp10852p10853.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
