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 c2316f6 [FLINK-11107] [state] Avoid memory stateBackend to create
arbitrary folders under HA path when no checkpoint path configured
new 4946cf4 [FLINK-12708][table] Introduce InputFormatTableSource and
make blink&flink planner support it
new 851d27b [FLINK-12708][table] Introduce OutputFormatTableSink and make
blink&flink planner support it
new 5be9ab3 [FLINK-12708][table] Introduce LookupableTableSource and make
blink planner support it
new 147022c [FLINK-12708][table] Expose getTableStats() interface in
TableSource
The 4 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:
.../apache/flink/table/sinks/BatchTableSink.java | 3 +
...amTableSink.java => OutputFormatTableSink.java} | 27 ++++-
.../apache/flink/table/sinks/StreamTableSink.java | 21 +++-
.../flink/table/sources/BatchTableSource.java | 3 +
...ableSource.java => InputFormatTableSource.java} | 30 ++++--
.../flink/table/sources/StreamTableSource.java | 8 ++
.../flink/table/functions/AsyncTableFunction.java | 62 +++---------
.../flink/table/sources/LookupableTableSource.java | 12 ++-
.../apache/flink/table/sources/TableSource.java | 10 ++
flink-table/flink-table-planner-blink/pom.xml | 6 ++
.../apache/flink/table/sources/LookupConfig.java | 111 ---------------------
.../flink/table/api/BatchTableEnvironment.scala | 69 +++++++------
.../flink/table/api/StreamTableEnvironment.scala | 67 +++++++------
.../apache/flink/table/api/TableEnvironment.scala | 16 ++-
.../table/codegen/LookupJoinCodeGenerator.scala | 5 +-
.../table/plan/nodes/common/CommonLookupJoin.scala | 39 +++-----
.../plan/nodes/physical/batch/BatchExecSink.scala | 29 ++++--
.../physical/batch/BatchExecTableSourceScan.scala | 13 +--
.../nodes/physical/stream/StreamExecSink.scala | 15 ++-
.../batch/BatchExecScanTableSourceRule.scala | 6 +-
.../table/plan/schema/BatchTableSourceTable.scala | 62 ------------
.../table/plan/schema/StreamTableSourceTable.scala | 62 ------------
.../table/plan/schema/TableSourceSinkTable.scala | 6 +-
.../flink/table/plan/schema/TableSourceTable.scala | 34 ++++++-
.../apache/flink/table/sinks/BatchTableSink.scala | 36 -------
.../flink/table/sinks/CollectTableSink.scala | 19 ++--
.../flink/table/sinks/RetractStreamTableSink.scala | 20 +++-
.../apache/flink/table/sinks/StreamTableSink.scala | 33 ------
.../flink/table/sinks/UpsertStreamTableSink.scala | 18 +++-
.../flink/table/sources/BatchTableSource.scala | 38 -------
.../flink/table/sources/StreamTableSource.scala | 38 -------
.../flink/table/api/batch/TableStatsTest.xml | 69 +++++++++++++
.../flink/table/api/batch/TableStatsTest.scala | 80 +++++++++++++++
.../plan/stream/sql/join/LookupJoinTest.scala | 68 ++++++-------
.../table/runtime/batch/sql/TableScanITCase.scala | 13 +--
.../batch/sql/agg/WindowAggregateITCase.scala | 20 ++--
.../table/runtime/stream/sql/TableScanITCase.scala | 2 +-
.../utils/InMemoryLookupableTableSource.scala | 42 ++------
.../flink/table/runtime/utils/StreamTestSink.scala | 31 +++---
.../apache/flink/table/util/TableTestBase.scala | 49 +++++----
.../apache/flink/table/util/testTableSources.scala | 10 +-
.../flink/table/catalog/DatabaseCalciteSchema.java | 2 +-
.../flink/table/plan/QueryOperationConverter.java | 2 +-
.../apache/flink/table/api/BatchTableEnvImpl.scala | 30 ++++--
.../flink/table/api/StreamTableEnvImpl.scala | 12 ++-
.../plan/nodes/dataset/BatchTableSourceScan.scala | 23 ++++-
.../rules/dataSet/BatchTableSourceScanRule.scala | 2 +-
.../flink/table/plan/stats/FlinkStatistic.scala | 2 +-
.../api/validation/TableSourceValidationTest.scala | 23 ++++-
.../runtime/batch/table/TableSinkITCase.scala | 33 +++++-
.../runtime/batch/table/TableSourceITCase.scala | 33 ++++++
.../table/utils/MemoryTableSourceSinkUtil.scala | 30 +++++-
.../flink/table/utils/testTableSources.scala | 24 ++++-
.../apache/flink/table/api/TableConfigOptions.java | 14 +++
.../join/lookup/DelegatingResultFuture.java | 55 ++++++++++
55 files changed, 847 insertions(+), 740 deletions(-)
copy
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/{StreamTableSink.java
=> OutputFormatTableSink.java} (51%)
copy
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/{StreamTableSource.java
=> InputFormatTableSource.java} (56%)
rename flink-table/{flink-table-planner-blink =>
flink-table-common}/src/main/java/org/apache/flink/table/functions/AsyncTableFunction.java
(57%)
rename flink-table/{flink-table-planner-blink =>
flink-table-common}/src/main/java/org/apache/flink/table/sources/LookupableTableSource.java
(83%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/sources/LookupConfig.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/plan/schema/BatchTableSourceTable.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/plan/schema/StreamTableSourceTable.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/sinks/BatchTableSink.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/sinks/StreamTableSink.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/sources/BatchTableSource.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/sources/StreamTableSource.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/api/batch/TableStatsTest.xml
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/batch/TableStatsTest.scala
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/join/lookup/DelegatingResultFuture.java
