Details

    • Release Note:
      Hide
      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))`.
      Show
      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))`.

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                twalthr Timo Walther
                Reporter:
                twalthr Timo Walther
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: