[FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas