This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9511243 [FLINK-16186][es][tests] Reduce connect timeout to 5 seconds
new f6895da [FLINK-15912][table] Add Context to TableSourceFactory and
TableSinkFactory
new 306a89a [FLINK-15912][table] Support create table source/sink by
context in sql-cli
new 69d8816 [FLINK-15912][table-planner-blink] Support create table
source/sink by context in blink planner
new e280ffc [FLINK-15912][table-planner] Support create table source/sink
by context in legacy planner
new 4e92bdb [FLINK-15912][table] Support create table source/sink by
context in hive connector
new 052eb77 [FLINK-15912][table] Clean TableFactoryUtil
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/connectors/hive/HiveTableFactory.java | 26 ++-----
.../connectors/hive/HiveTableFactoryTest.java | 16 +++-
.../flink/connectors/hive/HiveTableSourceTest.java | 3 +-
.../client/gateway/local/ExecutionContext.java | 37 ++++++---
.../gateway/utils/TestTableSinkFactoryBase.java | 11 +--
.../gateway/utils/TestTableSourceFactoryBase.java | 10 ++-
.../table/factories/StreamTableSinkFactory.java | 15 +++-
.../table/factories/StreamTableSourceFactory.java | 15 +++-
.../flink/table/catalog/CatalogTableImpl.java | 15 ++++
.../table/descriptors/ConnectTableDescriptor.java | 15 +---
.../flink/table/factories/TableFactoryUtil.java | 42 ++++-------
.../table/descriptors/DescriptorProperties.java | 19 +++++
.../flink/table/factories/TableSinkFactory.java | 49 +++++++++++-
.../TableSinkFactoryContextImpl.java} | 59 ++++++---------
.../flink/table/factories/TableSourceFactory.java | 49 +++++++++++-
.../TableSourceFactoryContextImpl.java} | 59 ++++++---------
.../table/planner/delegation/PlannerBase.scala | 16 ++--
.../planner/plan/schema/CatalogSourceTable.scala | 48 ++++++------
.../table/planner/plan/batch/sql/TableScanTest.xml | 8 +-
.../utils/TestCollectionTableFactory.scala | 53 ++++---------
.../table/planner/plan/batch/sql/SinkTest.scala | 31 --------
.../planner/plan/common/TableFactoryTest.scala | 88 ++++++++++++++++++++++
.../plan/utils/TestContextTableFactory.scala | 69 +++++++++++++++++
.../flink/table/catalog/CatalogCalciteSchema.java | 11 ++-
.../table/catalog/CatalogManagerCalciteSchema.java | 8 +-
.../flink/table/catalog/DatabaseCalciteSchema.java | 27 ++++---
.../flink/table/api/internal/TableEnvImpl.scala | 15 ++--
.../apache/flink/table/planner/StreamPlanner.scala | 16 ++--
.../table/catalog/DatabaseCalciteSchemaTest.java | 4 +-
.../table/sqlexec/SqlToOperationConverterTest.java | 2 +-
.../table/api/stream/sql/TableFactoryTest.scala | 74 ++++++++++++++++++
.../table/utils/TestContextTableFactory.scala | 69 +++++++++++++++++
32 files changed, 673 insertions(+), 306 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/{api/constraints/AbstractConstraint.java
=> factories/TableSinkFactoryContextImpl.java} (53%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/{api/constraints/AbstractConstraint.java
=> factories/TableSourceFactoryContextImpl.java} (52%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/common/TableFactoryTest.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/utils/TestContextTableFactory.scala
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/stream/sql/TableFactoryTest.scala
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/utils/TestContextTableFactory.scala
