[FLINK-11827] Introduce DataFormatConverters to convert internal data format and java format

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.9.0
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 05/Mar/19 13:26
• Updated: 06/Mar/19 06:35
• Resolved: 06/Mar/19 06:35

Description

We have introduced a new internal data format, but if user interact with Source, sink and Udx, they prefer to use the traditional Java data format.

So we introduce DataFormat Converters to convert the internal efficient binary data format into more general Java data format when source, sink and UDX are used.

Issue Links

• is a child of: FLINK-11488 Add a basic Blink planner framework
• links to: GitHub Pull Request #7904