You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2020/05/10 11:50:38 UTC
[flink] branch master updated (5bf121a -> 55d04d5)

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

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


    from 5bf121a  [FLINK-17564][checkpointing] Fix buffer disorder issue of RemoteInputChannel for unaligned checkpoint
     add 55d04d5  [FLINK-16367][table] Introduce TableEnvironment#createStatementSet api

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/__init__.py             |   6 +-
 flink-python/pyflink/table/statement_set.py        |  93 +++++++++++++++
 flink-python/pyflink/table/table_environment.py    |  13 +++
 .../table/tests/test_table_environment_api.py      |  40 +++++++
 .../org/apache/flink/table/api/StatementSet.java   |  65 +++++++++++
 .../apache/flink/table/api/TableEnvironment.java   |   7 ++
 .../flink/table/api/internal/StatementSetImpl.java | 102 +++++++++++++++++
 .../table/api/internal/TableEnvironmentImpl.java   |  69 +++++++-----
 .../test/resources/explain/testStatementSet.out    |  63 +++++++++++
 .../flink/table/api/TableEnvironmentITCase.scala   | 125 +++++++++++++++++++--
 .../flink/table/api/internal/TableEnvImpl.scala    |  66 +++++++----
 .../flink/table/api/TableEnvironmentITCase.scala   | 104 +++++++++++++++--
 .../runtime/batch/sql/TableEnvironmentITCase.scala |  82 ++++++++++++--
 .../flink/table/utils/MockTableEnvironment.scala   |   4 +-
 ...treamAndSqlUpdate.out => testStatementSet0.out} |  30 +++++
 .../src/test/scala/resources/testStatementSet1.out |  81 +++++++++++++
 16 files changed, 864 insertions(+), 86 deletions(-)
 create mode 100644 flink-python/pyflink/table/statement_set.py
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/StatementSet.java
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/StatementSetImpl.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/explain/testStatementSet.out
 copy flink-table/flink-table-planner/src/test/scala/resources/{testFromToDataStreamAndSqlUpdate.out => testStatementSet0.out} (52%)
 create mode 100644 flink-table/flink-table-planner/src/test/scala/resources/testStatementSet1.out