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

Posted to commits@flink.apache.org by ja...@apache.org on 2019/11/01 12:39:12 UTC

[flink] branch master updated (1ffbcfb -> 3011bff)

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

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


    from 1ffbcfb  [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough into chinese (#9749)
     add 3011bff  [FLINK-14322][table-api] Add watermark information in TableSchema (#9994)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/table/api/TableSchema.java    | 152 +++++++++++++----
 .../org/apache/flink/table/api/WatermarkSpec.java  |  92 ++++++++++
 .../table/descriptors/DescriptorProperties.java    |  48 ++++++
 .../apache/flink/table/api/TableSchemaTest.java    | 187 +++++++++++++++++++++
 .../descriptors/DescriptorPropertiesTest.java      |  37 ++++
 .../flink/table/api/TableEnvironmentTest.scala     |  33 ++++
 .../apache/flink/table/api/TableSchemaTest.scala   | 105 ------------
 .../api/validation/TableSchemaValidationTest.scala |  12 +-
 .../api/validation/TableSinksValidationTest.scala  |   2 +-
 9 files changed, 521 insertions(+), 147 deletions(-)
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java
 create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/api/TableSchemaTest.java
 delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableSchemaTest.scala