This is an automated email from the ASF dual-hosted git repository.
fanng pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/gravitino.git
from 3ba81470bc [#6075] improvement(core): Add event listener support for
Model system (#6703)
add e6de52ad01 [#6233] feat(flink): flink jdbc catalog (#6543)
No new revisions were added by this update.
Summary of changes:
flink-connector/flink/build.gradle.kts | 2 +
.../flink/connector/PropertiesConverter.java | 15 +-
...erter.java => UnsupportPartitionConverter.java} | 26 ++-
.../flink/connector/catalog/BaseCatalog.java | 9 +-
.../flink/connector/hive/GravitinoHiveCatalog.java | 4 +-
.../hive/GravitinoHiveCatalogFactory.java | 1 +
.../connector/hive/HivePropertiesConverter.java | 8 +-
.../connector/iceberg/GravitinoIcebergCatalog.java | 12 +-
.../GravitinoJdbcCatalog.java} | 48 ++---
.../GravitinoJdbcCatalogFactory.java} | 53 +++---
.../GravitinoJdbcCatalogFactoryOptions.java} | 16 +-
.../connector/jdbc/JdbcPropertiesConstants.java | 55 ++++++
.../connector/jdbc/JdbcPropertiesConverter.java | 101 ++++++++++
.../mysql/GravitinoMysqlJdbcCatalogFactory.java | 28 ++-
.../jdbc/mysql/MysqlPropertiesConverter.java | 22 ++-
.../GravitinoPostgresJdbcCatalogFactory.java | 33 ++--
.../postgresql/PostgresqlPropertiesConverter.java | 22 ++-
.../connector/paimon/GravitinoPaimonCatalog.java | 7 +-
.../org.apache.flink.table.factories.Factory | 2 +
.../connector/integration/test/FlinkCommonIT.java | 52 ++++-
.../connector/integration/test/FlinkEnvIT.java | 8 +-
.../integration/test/hive/FlinkHiveCatalogIT.java | 1 -
.../test/iceberg/FlinkIcebergCatalogIT.java | 1 -
.../test/jdbc/FlinkJdbcMysqlCatalogIT.java | 210 +++++++++++++++++++++
.../test/paimon/FlinkPaimonCatalogIT.java | 2 +-
.../integration/test/utils/TestUtils.java | 14 --
.../AbstractJdbcPropertiesConverterTestSuite.java | 156 +++++++++++++++
.../jdbc/TestMysqlPropertiesConverter.java | 13 +-
.../jdbc/TestPostgresqlPropertiesConverter.java | 13 +-
gradle/libs.versions.toml | 2 +
30 files changed, 748 insertions(+), 188 deletions(-)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{DefaultPartitionConverter.java
=> UnsupportPartitionConverter.java} (59%)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{hive/GravitinoHiveCatalog.java
=> jdbc/GravitinoJdbcCatalog.java} (57%)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{paimon/GravitinoPaimonCatalogFactory.java
=> jdbc/GravitinoJdbcCatalogFactory.java} (61%)
copy
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/{iceberg/GravitinoIcebergCatalogFactoryOptions.java
=> jdbc/GravitinoJdbcCatalogFactoryOptions.java} (68%)
create mode 100644
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/JdbcPropertiesConstants.java
create mode 100644
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/JdbcPropertiesConverter.java
copy
iceberg/iceberg-common/src/test/java/org/apache/gravitino/iceberg/common/utils/CustomCatalogForTest.java
=>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/mysql/GravitinoMysqlJdbcCatalogFactory.java
(57%)
copy
spark-connector/spark-common/src/main/java/org/apache/gravitino/spark/connector/plugin/GravitinoSparkPlugin.java
=>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/mysql/MysqlPropertiesConverter.java
(58%)
copy core/src/test/java/org/apache/gravitino/audit/DummyAuditWriter.java =>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/postgresql/GravitinoPostgresJdbcCatalogFactory.java
(56%)
copy
spark-connector/v3.4/spark/src/main/java/org/apache/gravitino/spark/connector/jdbc/GravitinoJdbcCatalogSpark34.java
=>
flink-connector/flink/src/main/java/org/apache/gravitino/flink/connector/jdbc/postgresql/PostgresqlPropertiesConverter.java
(57%)
create mode 100644
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/jdbc/FlinkJdbcMysqlCatalogIT.java
create mode 100644
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/jdbc/AbstractJdbcPropertiesConverterTestSuite.java
copy
catalogs/catalog-model/src/main/java/org/apache/gravitino/catalog/model/ModelPropertiesMetadata.java
=>
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/jdbc/TestMysqlPropertiesConverter.java
(70%)
copy
catalogs/catalog-kafka/src/main/java/org/apache/gravitino/catalog/kafka/KafkaSchemaPropertiesMetadata.java
=>
flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/jdbc/TestPostgresqlPropertiesConverter.java
(69%)
