This is an automated email from the ASF dual-hosted git repository.
yuqi4733 pushed a change to branch fix-10464-iceberg-event-decouple
in repository https://gitbox.apache.org/repos/asf/gravitino.git
from 445eae3ff1 [#10464] refactor(iceberg): decouple listener events from
Iceberg API models
add d8e83e31cb [#10464] refactor(iceberg): split listener API into
standalone module
No new revisions were added by this update.
Summary of changes:
.../iceberg-listener-api/build.gradle.kts | 19 +++++---
.../api/event/IcebergCreateNamespaceEvent.java | 5 +-
.../event/IcebergCreateNamespaceFailureEvent.java | 3 +-
.../api/event/IcebergCreateNamespacePreEvent.java | 7 ++-
.../api/event/IcebergCreateTableEvent.java | 5 +-
.../api/event/IcebergCreateTableFailureEvent.java | 3 +-
.../api/event/IcebergCreateTablePreEvent.java | 7 ++-
.../listener/api/event/IcebergCreateViewEvent.java | 5 +-
.../api/event/IcebergCreateViewFailureEvent.java | 3 +-
.../api/event/IcebergCreateViewPreEvent.java | 7 ++-
.../api/event/IcebergDropNamespaceEvent.java | 0
.../event/IcebergDropNamespaceFailureEvent.java | 0
.../api/event/IcebergDropNamespacePreEvent.java | 0
.../listener/api/event/IcebergDropTableEvent.java | 0
.../api/event/IcebergDropTableFailureEvent.java | 0
.../api/event/IcebergDropTablePreEvent.java | 0
.../listener/api/event/IcebergDropViewEvent.java | 0
.../api/event/IcebergDropViewFailureEvent.java | 0
.../api/event/IcebergDropViewPreEvent.java | 0
.../gravitino/listener/api/event/IcebergEvent.java | 0
.../listener/api/event/IcebergEventUtils.java | 56 ++++++++++++++++++++++
.../listener/api/event/IcebergFailureEvent.java | 0
.../api/event/IcebergListNamespacesEvent.java | 0
.../event/IcebergListNamespacesFailureEvent.java | 0
.../api/event/IcebergListNamespacesPreEvent.java | 0
.../listener/api/event/IcebergListTableEvent.java | 0
.../api/event/IcebergListTableFailureEvent.java | 0
.../api/event/IcebergListTablePreEvent.java | 0
.../listener/api/event/IcebergListViewEvent.java | 0
.../api/event/IcebergListViewFailureEvent.java | 0
.../api/event/IcebergListViewPreEvent.java | 0
.../api/event/IcebergLoadNamespaceEvent.java | 3 +-
.../event/IcebergLoadNamespaceFailureEvent.java | 0
.../api/event/IcebergLoadNamespacePreEvent.java | 0
.../api/event/IcebergLoadTableCredentialEvent.java | 0
.../IcebergLoadTableCredentialFailureEvent.java | 0
.../event/IcebergLoadTableCredentialPreEvent.java | 0
.../listener/api/event/IcebergLoadTableEvent.java | 3 +-
.../api/event/IcebergLoadTableFailureEvent.java | 0
.../api/event/IcebergLoadTablePreEvent.java | 0
.../listener/api/event/IcebergLoadViewEvent.java | 3 +-
.../api/event/IcebergLoadViewFailureEvent.java | 0
.../api/event/IcebergLoadViewPreEvent.java | 0
.../listener/api/event/IcebergNamespaceEvent.java | 0
.../api/event/IcebergNamespaceExistsEvent.java | 0
.../event/IcebergNamespaceExistsFailureEvent.java | 0
.../api/event/IcebergNamespaceExistsPreEvent.java | 0
.../api/event/IcebergNamespaceFailureEvent.java | 0
.../api/event/IcebergNamespacePreEvent.java | 0
.../api/event/IcebergPlanTableScanEvent.java | 0
.../event/IcebergPlanTableScanFailureEvent.java | 0
.../api/event/IcebergPlanTableScanPreEvent.java | 0
.../listener/api/event/IcebergPreEvent.java | 0
.../api/event/IcebergRegisterTableEvent.java | 5 +-
.../event/IcebergRegisterTableFailureEvent.java | 3 +-
.../api/event/IcebergRegisterTablePreEvent.java | 7 ++-
.../api/event/IcebergRenameTableEvent.java | 3 +-
.../api/event/IcebergRenameTableFailureEvent.java | 0
.../api/event/IcebergRenameTablePreEvent.java | 7 ++-
.../listener/api/event/IcebergRenameViewEvent.java | 3 +-
.../api/event/IcebergRenameViewFailureEvent.java | 0
.../api/event/IcebergRenameViewPreEvent.java | 7 ++-
.../api/event/IcebergReplaceViewEvent.java | 5 +-
.../api/event/IcebergReplaceViewFailureEvent.java | 3 +-
.../api/event/IcebergReplaceViewPreEvent.java | 7 ++-
.../listener/api/event/IcebergRequestContext.java | 3 +-
.../listener/api/event/IcebergTableEvent.java | 0
.../api/event/IcebergTableExistsEvent.java | 0
.../api/event/IcebergTableExistsFailureEvent.java | 0
.../api/event/IcebergTableExistsPreEvent.java | 0
.../api/event/IcebergTableFailureEvent.java | 0
.../listener/api/event/IcebergTablePreEvent.java | 0
.../api/event/IcebergUpdateNamespaceEvent.java | 5 +-
.../event/IcebergUpdateNamespaceFailureEvent.java | 3 +-
.../api/event/IcebergUpdateNamespacePreEvent.java | 7 ++-
.../api/event/IcebergUpdateTableEvent.java | 5 +-
.../api/event/IcebergUpdateTableFailureEvent.java | 3 +-
.../api/event/IcebergUpdateTablePreEvent.java | 7 ++-
.../listener/api/event/IcebergViewEvent.java | 0
.../listener/api/event/IcebergViewExistsEvent.java | 0
.../api/event/IcebergViewExistsFailureEvent.java | 0
.../api/event/IcebergViewExistsPreEvent.java | 0
.../api/event/IcebergViewFailureEvent.java | 0
.../listener/api/event/IcebergViewPreEvent.java | 0
iceberg/iceberg-rest-server/build.gradle.kts | 1 +
.../IcebergNamespaceEventDispatcher.java | 37 +++++++++-----
.../dispatcher/IcebergTableEventDispatcher.java | 36 +++++++++-----
.../dispatcher/IcebergViewEventDispatcher.java | 37 ++++++++++----
settings.gradle.kts | 1 +
89 files changed, 202 insertions(+), 122 deletions(-)
copy
maintenance/updaters/src/main/java/org/apache/gravitino/maintenance/optimizer/updater/metrics/storage/jdbc/H2MetricsDialect.java
=> iceberg/iceberg-listener-api/build.gradle.kts (75%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateNamespaceEvent.java
(87%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateNamespaceFailureEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateNamespacePreEvent.java
(86%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateTableEvent.java
(88%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateTableFailureEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateTablePreEvent.java
(87%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateViewEvent.java
(88%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateViewFailureEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergCreateViewPreEvent.java
(88%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropNamespaceEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropNamespaceFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropNamespacePreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropTableEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropTableFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropTablePreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropViewEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropViewFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergDropViewPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergEvent.java
(100%)
create mode 100644
iceberg/iceberg-listener-api/src/main/java/org/apache/gravitino/listener/api/event/IcebergEventUtils.java
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListNamespacesEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListNamespacesFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListNamespacesPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListTableEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListTableFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListTablePreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListViewEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListViewFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergListViewPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadNamespaceEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadNamespaceFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadNamespacePreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadTableCredentialEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadTableCredentialFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadTableCredentialPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadTableEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadTableFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadTablePreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadViewEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadViewFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergLoadViewPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergNamespaceEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergNamespaceExistsEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergNamespaceExistsFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergNamespaceExistsPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergNamespaceFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergNamespacePreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergPlanTableScanEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergPlanTableScanFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergPlanTableScanPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRegisterTableEvent.java
(88%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRegisterTableFailureEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRegisterTablePreEvent.java
(86%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRenameTableEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRenameTableFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRenameTablePreEvent.java
(87%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRenameViewEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRenameViewFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRenameViewPreEvent.java
(87%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergReplaceViewEvent.java
(88%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergReplaceViewFailureEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergReplaceViewPreEvent.java
(88%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergRequestContext.java
(96%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergTableEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergTableExistsEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergTableExistsFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergTableExistsPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergTableFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergTablePreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergUpdateNamespaceEvent.java
(90%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergUpdateNamespaceFailureEvent.java
(92%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergUpdateNamespacePreEvent.java
(83%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergUpdateTableEvent.java
(88%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergUpdateTableFailureEvent.java
(91%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergUpdateTablePreEvent.java
(87%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergViewEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergViewExistsEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergViewExistsFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergViewExistsPreEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergViewFailureEvent.java
(100%)
rename iceberg/{iceberg-rest-server =>
iceberg-listener-api}/src/main/java/org/apache/gravitino/listener/api/event/IcebergViewPreEvent.java
(100%)
