This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2072026 [FLINK-23312][ci] speed up compilation for e2e tests
add 5d7a96a [FLINK-23069][table-api-java] Support schemaless
Table#executeInsert(TableDescriptor)
add 871dbd1 [FLINK-23069][table-api-java] Rename ExternalSchemaTranslator
add 64f1430 [FLINK-23069][table-api-java] Support schemaless
StatementSet#addInsert
No new revisions were added by this update.
Summary of changes:
.../java/internal/StreamTableEnvironmentImpl.java | 24 ++---
.../org/apache/flink/table/api/StatementSet.java | 27 ++++++
.../java/org/apache/flink/table/api/Table.java | 27 ++++++
.../apache/flink/table/api/TableDescriptor.java | 51 +++++++---
.../flink/table/api/internal/StatementSetImpl.java | 17 +++-
.../table/api/internal/TableEnvironmentImpl.java | 38 ++++----
.../apache/flink/table/api/internal/TableImpl.java | 13 ++-
...SchemaTranslator.java => SchemaTranslator.java} | 76 ++++++++++-----
.../flink/table/api/TableDescriptorTest.java | 11 ++-
...anslatorTest.java => SchemaTranslatorTest.java} | 48 +++++-----
.../internal/StreamTableEnvironmentImpl.scala | 18 ++--
.../runtime/stream/table/TableSinkITCase.scala | 103 ++++++++++++++++-----
12 files changed, 326 insertions(+), 127 deletions(-)
rename
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/{ExternalSchemaTranslator.java
=> SchemaTranslator.java} (89%)
rename
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/{ExternalSchemaTranslatorTest.java
=> SchemaTranslatorTest.java} (92%)