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 6e61339 [FLINK-17068][python][tests] Ensure the permission of scripts
set correctly before executing the Python tests (#11805)
add e0d2db7 [FLINK-16366] [table] Introduce executeSql method in
TableEnvironment
No new revisions were added by this update.
Summary of changes:
.../test-scripts/test_table_shaded_dependencies.sh | 2 +
flink-python/pyflink/table/table_environment.py | 14 ++
flink-table/flink-sql-client/pom.xml | 8 -
.../table/client/cli/CliChangelogResultView.java | 4 +-
.../flink/table/client/cli/CliTableResultView.java | 3 +-
.../table/client/cli/CliTableauResultView.java | 119 +-----------
.../apache/flink/table/client/cli/CliUtils.java | 46 -----
.../src/main/resources/META-INF/NOTICE | 1 -
.../table/client/cli/CliTableauResultViewTest.java | 2 +-
.../flink/table/client/cli/CliUtilsTest.java | 68 -------
.../org/apache/flink/table/api/ResultKind.java} | 17 +-
.../apache/flink/table/api/TableEnvironment.java | 13 ++
.../api/{PlannerConfig.java => TableResult.java} | 45 +++--
.../table/api/internal/TableEnvironmentImpl.java | 154 +++++++++++----
.../flink/table/api/internal/TableResultImpl.java | 170 ++++++++++++++++
.../table/operations/ShowCatalogsOperation.java | 10 +-
.../table/operations/ShowDatabasesOperation.java | 10 +-
.../table/operations/ShowFunctionsOperation.java | 10 +-
.../flink/table/operations/ShowOperation.java} | 11 +-
.../table/operations/ShowTablesOperation.java | 10 +-
flink-table/flink-table-common/pom.xml | 9 +
.../org/apache/flink/table/utils/PrintUtils.java | 216 +++++++++++++++++++++
.../apache/flink/table/utils/PrintUtilsTest.java | 201 +++++++++++++++++++
flink-table/flink-table-planner-blink/pom.xml | 10 +
.../operations/SqlToOperationConverter.java | 36 ++++
.../src/main/resources/META-INF/NOTICE | 1 +
.../main/resources/META-INF/licenses/LICENSE.icu4j | 0
.../table/planner/calcite/FlinkPlannerImpl.scala | 7 +-
.../flink/table/api/TableEnvironmentTest.scala | 183 ++++++++++++++++-
flink-table/flink-table-planner/pom.xml | 10 +
.../table/sqlexec/SqlToOperationConverter.java | 36 ++++
.../src/main/resources/META-INF/NOTICE | 1 +
.../main/resources/META-INF/licenses/LICENSE.icu4j | 0
.../flink/table/api/internal/TableEnvImpl.scala | 134 ++++++++++---
.../flink/table/calcite/FlinkPlannerImpl.scala | 7 +-
.../api/batch/BatchTableEnvironmentTest.scala | 202 ++++++++++++++++++-
.../flink/table/utils/MockTableEnvironment.scala | 4 +-
flink-table/flink-table-uber-blink/pom.xml | 7 +
flink-table/flink-table-uber/pom.xml | 7 +
39 files changed, 1426 insertions(+), 362 deletions(-)
delete mode 100644
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliUtilsTest.java
copy
flink-table/{flink-table-common/src/main/java/org/apache/flink/table/api/ExpressionParserException.java
=>
flink-table-api-java/src/main/java/org/apache/flink/table/api/ResultKind.java}
(71%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/{PlannerConfig.java
=> TableResult.java} (54%)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableResultImpl.java
copy
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureFSFactory.java
=>
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowCatalogsOperation.java
(79%)
copy
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureFSFactory.java
=>
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowDatabasesOperation.java
(79%)
copy
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureFSFactory.java
=>
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowFunctionsOperation.java
(79%)
copy
flink-table/{flink-table-common/src/main/java/org/apache/flink/table/functions/python/PythonFunctionKind.java
=>
flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowOperation.java}
(80%)
copy
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureFSFactory.java
=>
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowTablesOperation.java
(79%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/PrintUtilsTest.java
copy flink-table/{flink-sql-client =>
flink-table-planner-blink}/src/main/resources/META-INF/licenses/LICENSE.icu4j
(100%)
rename flink-table/{flink-sql-client =>
flink-table-planner}/src/main/resources/META-INF/licenses/LICENSE.icu4j (100%)
