Hi folks, I'd like to kick off the discussion of FLIP-421[1].
The motivation is to support custom conversion between Flink SQL internal data classes and external classes. The typical scenarios of these conversions are: 1. In source / sink 2. conversion between Table and DataStream. I think this FLIP will help improve the user experience in format development (It makes the implementation of FLIP-358[2] much easier). And it also makes the table-datastream conversion more usable. Comments are welcome! Thanks, Jiangjie (Becket) Qin [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-421%3A+Support+Custom+Conversion+for+LogicalTypes [2] https://cwiki.apache.org/confluence/display/FLINK/FLIP-358%3A+flink-avro+enhancement+and+cleanup
