[FLINK-19977] Add new StreamTableEnvironment.fromDataStream

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Table SQL / API
• Labels: pull-request-available

Release Note

StreamTableEnvironment.fromDataStream has slightly different semantics now because it has been integrated into the new type system. Esp. row fields derived from composite type information might be in a different order compared to 1.12. The old behavior is still available via the overloaded method that takes expressions like `fromDataStream(ds, $("field1"), $("field2))`.

• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 04/Nov/20 15:31
• Updated: 28/Aug/21 11:12
• Resolved: 03/May/21 06:50

Description

The DataStream API itself is not a changelog processor. Therefore, in most of the cases, the DataStream API produces insert-only events of different data types. Insert-only semantics make the handling of different record types easier because we don't require a Row or RowData to contain a RowKind flag. It is therefore possible to offer the conversion of any data type to an insert-only table, without the necessity of performing manual schema work.

Goal: Convert between table and DataStream as easy as possible.

Issue Links

• links to: GitHub Pull Request #15428