I haven't tried it yet, but I saw flink-spector which seems to actually do what I want..
https://github.com/ottogroup/flink-spector/wiki/Defining-Input Although having it as part of the normal API would be nice as that library is already out of date (1.5.0) -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
