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 6d89c1d [FLINK-23560][runtime] Calculate absoluteTimeMillis only once
for idle metric and throughput calculation. (#16772)
add 6d0263f [FLINK-23720][table] Migrate ModuleFactory to the new stack
No new revisions were added by this update.
Summary of changes:
.../table/module/hive/HiveModuleDescriptor.java | 52 ---------
.../module/hive/HiveModuleDescriptorValidator.java | 35 ------
.../flink/table/module/hive/HiveModuleFactory.java | 59 +++++------
.../flink/table/module/hive/HiveModuleOptions.java | 15 ++-
.../org.apache.flink.table.factories.Factory | 1 +
.../org.apache.flink.table.factories.TableFactory | 1 -
.../module/hive/HiveModuleDescriptorTest.java | 55 ----------
.../table/module/hive/HiveModuleFactoryTest.java | 17 ++-
.../table/client/gateway/local/DependencyTest.java | 31 ------
.../org.apache.flink.table.factories.TableFactory | 16 ---
.../src/test/resources/sql/module.q | 16 +--
.../table/api/internal/TableEnvironmentImpl.java | 25 ++---
.../table/operations/LoadModuleOperation.java | 44 +++++---
.../flink/table/module/ModuleManagerTest.java | 4 +-
.../table/catalog/exceptions/CatalogException.java | 3 +
.../flink/table/descriptors/ModuleDescriptor.java | 67 ------------
.../descriptors/ModuleDescriptorValidator.java | 35 ------
.../apache/flink/table/factories/FactoryUtil.java | 118 ++++++++++++++++++++-
.../flink/table/factories/ModuleFactory.java | 87 ++++++++++++++-
.../CommonModuleOptions.java} | 21 ++--
.../flink/table/module/CoreModuleFactory.java | 27 +++--
.../flink/table/module/ModuleException.java} | 21 ++--
...ry => org.apache.flink.table.factories.Factory} | 0
.../factories/module/CoreModuleFactoryTest.java | 17 +--
.../table/factories/module/DummyModuleFactory.java | 44 +++-----
.../module/LegacyDummyModuleFactory.java} | 33 +++---
.../org.apache.flink.table.factories.Factory | 1 +
.../org.apache.flink.table.factories.TableFactory | 2 +-
.../operations/SqlToOperationConverterTest.java | 8 +-
.../flink/table/api/TableEnvironmentTest.scala | 22 ++--
30 files changed, 385 insertions(+), 492 deletions(-)
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModuleDescriptor.java
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModuleDescriptorValidator.java
copy
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFormatOptions.java
=>
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModuleOptions.java
(71%)
delete mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleDescriptorTest.java
delete mode 100644
flink-table/flink-sql-client/src/test/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ModuleDescriptor.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ModuleDescriptorValidator.java
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/{catalog/CommonCatalogOptions.java
=> module/CommonModuleOptions.java} (68%)
copy
flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/api/SqlParserException.java
=>
flink-table-common/src/main/java/org/apache/flink/table/module/ModuleException.java}
(70%)
rename
flink-table/flink-table-common/src/main/resources/META-INF/services/{org.apache.flink.table.factories.TableFactory
=> org.apache.flink.table.factories.Factory} (100%)
copy
flink-table/flink-table-common/src/{main/java/org/apache/flink/table/module/CoreModuleFactory.java
=>
test/java/org/apache/flink/table/factories/module/LegacyDummyModuleFactory.java}
(62%)
