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 967b89c [FLINK-17092][python] Add retry when pip install dependencies
(#12024)
add 1de54fe [FLINK-17251] [table] Introduce Table#executeInsert & add
insert statement support to TableEnvironment#executeSql
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/table/table.py | 21 ++
.../java/org/apache/flink/table/api/Table.java | 57 +++++
.../table/api/internal/TableEnvironmentImpl.java | 52 ++++-
.../api/internal/TableEnvironmentInternal.java | 59 ++++++
.../apache/flink/table/api/internal/TableImpl.java | 32 ++-
.../flink/table/api/internal/TableResultImpl.java | 2 +-
.../apache/flink/table/delegation/Executor.java | 10 +
.../org/apache/flink/table/utils/ExecutorMock.java | 6 +
.../table/planner/delegation/ExecutorBase.java | 6 +
.../flink/table/api/TableEnvironmentITCase.scala | 202 +++++++++++++++++-
.../flink/table/executor/StreamExecutor.java | 6 +
.../table/api/internal/BatchTableEnvImpl.scala | 108 ++++++----
.../flink/table/api/internal/TableEnvImpl.scala | 168 ++++++++++-----
.../flink/table/api/TableEnvironmentITCase.scala | 152 ++++++++++++++
.../runtime/batch/sql/TableEnvironmentITCase.scala | 231 ++++++++++++++++++++-
.../apache/flink/table/utils/testTableSinks.scala | 87 ++++++++
16 files changed, 1097 insertions(+), 102 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentInternal.java
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/utils/testTableSinks.scala
