You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by tw...@apache.org on 2021/04/22 08:28:50 UTC

[flink] branch master updated (a493a6b -> 4b5e8cc)

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from a493a6b  [FLINK-22396][hbase] Remove unnecessary entries from shaded plugin configuration
     add c54a15d  [FLINK-19980][table-common] Add a ChangelogMode.upsert() shortcut
     add 923e161  [FLINK-19980][table-common] Add a ChangelogMode.all() shortcut
     add 4b5e8cc  [FLINK-19980][table] Support fromChangelogStream/toChangelogStream

No new revisions were added by this update.

Summary of changes:
 .../api/bridge/java/StreamTableEnvironment.java    | 282 ++++++++++++++++++++-
 .../java/internal/StreamTableEnvironmentImpl.java  | 125 ++++++---
 .../table/catalog/ExternalSchemaTranslator.java    | 130 +++++++++-
 .../table/operations/ExternalModifyOperation.java  |  10 +-
 .../catalog/ExternalSchemaTranslatorTest.java      | 106 +++++++-
 .../api/bridge/scala/StreamTableEnvironment.scala  | 262 ++++++++++++++++++-
 .../internal/StreamTableEnvironmentImpl.scala      | 138 +++++++---
 .../flink/table/connector/ChangelogMode.java       |  28 ++
 .../table/planner/connectors/DynamicSinkUtils.java |   2 +-
 .../planner/connectors/ExternalDynamicSink.java    |  42 ++-
 .../planner/connectors/ExternalDynamicSource.java  |  10 +-
 .../planner/factories/TestValuesTableFactory.java  |   8 +-
 .../runtime/stream/sql/DataStreamJavaITCase.java   | 166 ++++++++++++
 .../operators/sink/OutputConversionOperator.java   |  11 +-
 .../operators/source/InputConversionOperator.java  |   8 +-
 15 files changed, 1202 insertions(+), 126 deletions(-)