This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4412c6e [minor] Add debug logging if aws cli command fails
add 612e1e9 [FLINK-16035] Updated Stream/BatchTableEnvironment.java to
use Java's Expression DSL
add fab6c2a [FLINK-16036][table-api] Deprecate String based Expression
DSL in TableEnvironments
No new revisions were added by this update.
Summary of changes:
.../cassandra/CassandraConnectorITCase.java | 2 +-
.../flink/addons/hbase/HBaseConnectorITCase.java | 11 +-
.../api/java/io/jdbc/JDBCLookupFunctionITCase.java | 4 +-
.../java/io/jdbc/JDBCUpsertTableSinkITCase.java | 14 +-
.../table/examples/java/StreamSQLExample.java | 6 +-
.../table/examples/scala/StreamSQLExample.scala | 2 +-
.../ml/common/utils/DataStreamConversionUtil.java | 13 +-
.../PythonScalarFunctionOperatorTestBase.java | 4 +-
.../table/api/java/BatchTableEnvironment.java | 188 ++++++++++++++++-
.../table/api/java/StreamTableEnvironment.java | 225 ++++++++++++++++++++-
.../java/internal/StreamTableEnvironmentImpl.java | 16 +-
.../operations/JavaDataStreamQueryOperation.java | 3 +-
.../operations/ScalaDataStreamQueryOperation.java | 2 +-
.../table/api/scala/BatchTableEnvironment.scala | 100 ++++++++-
.../table/api/scala/StreamTableEnvironment.scala | 121 ++++++++++-
.../flink/table/api/TableUtilsStreamingITCase.java | 3 +-
.../flink/table/api/TableEnvironmentTest.scala | 2 +-
.../expressions/utils/ExpressionTestBase.scala | 2 +-
.../planner/match/PatternTranslatorTestBase.scala | 2 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 5 +-
.../runtime/stream/sql/AggregateRemoveITCase.scala | 6 +-
.../stream/sql/PruneAggregateCallITCase.scala | 4 +-
.../planner/runtime/utils/BatchTableEnvUtil.scala | 2 +-
.../planner/runtime/utils/StreamTableEnvUtil.scala | 4 +-
.../flink/table/planner/utils/TableTestBase.scala | 4 +-
.../java/internal/BatchTableEnvironmentImpl.scala | 17 +-
.../runtime/batch/sql/GroupingSetsITCase.java | 4 +-
.../table/runtime/batch/sql/JavaSqlITCase.java | 14 +-
.../batch/table/JavaTableEnvironmentITCase.java | 92 ++++-----
.../table/runtime/stream/sql/JavaSqlITCase.java | 12 +-
.../table/api/batch/sql/SetOperatorsTest.scala | 4 +-
.../table/api/batch/table/SetOperatorsTest.scala | 8 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 6 +-
.../api/stream/StreamTableEnvironmentTest.scala | 24 ++-
.../flink/table/api/stream/sql/UnionTest.scala | 6 +-
.../api/stream/table/TableAggregateTest.scala | 4 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 6 +-
.../TableEnvironmentValidationTest.scala | 6 +-
.../expressions/utils/ExpressionTestBase.scala | 2 +-
.../table/match/PatternTranslatorTestBase.scala | 2 +-
.../table/runtime/batch/sql/AggregateITCase.scala | 22 +-
.../flink/table/runtime/batch/sql/CalcITCase.scala | 8 +-
.../flink/table/runtime/batch/sql/JoinITCase.scala | 8 +-
.../runtime/batch/sql/SetOperatorsITCase.scala | 40 ++--
.../flink/table/runtime/batch/sql/SortITCase.scala | 8 +-
.../runtime/batch/sql/TableEnvironmentITCase.scala | 2 +-
.../runtime/batch/table/AggregateITCase.scala | 2 +-
.../table/runtime/batch/table/CalcITCase.scala | 6 +-
.../batch/table/TableEnvironmentITCase.scala | 6 +-
.../runtime/stream/sql/InsertIntoITCase.scala | 16 +-
.../flink/table/runtime/stream/sql/SqlITCase.scala | 10 +-
.../apache/flink/table/utils/TableTestBase.scala | 17 +-
52 files changed, 874 insertions(+), 223 deletions(-)
