This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 36b69d8 [HUDI-2935] Remove special casing of clustering in
deltastreamer checkpoint retrival (#4216)
add a8fb696 [HUDI-2877] Support flink catalog to help user use flink
table conveniently (#4153)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/table/catalog/CatalogOptions.java | 56 +++
.../apache/hudi/table/catalog/HoodieCatalog.java | 508 +++++++++++++++++++++
.../hudi/table/catalog/HoodieCatalogFactory.java | 72 +++
.../hudi/table/catalog/TableOptionProperties.java | 131 ++++++
.../java/org/apache/hudi/util/StreamerUtil.java | 1 +
.../org.apache.flink.table.factories.Factory | 1 +
.../hudi/table/catalog/TestHoodieCatalog.java | 258 +++++++++++
7 files changed, 1027 insertions(+)
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/table/catalog/CatalogOptions.java
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalog.java
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalogFactory.java
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/table/catalog/TableOptionProperties.java
create mode 100644
hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java
