Skip to content

Commit e23fd78

Browse files
committed
[#6097] fix(core): Support model failure event to Gravitino server
add DeveloperApi to failure event class.
1 parent 44c130c commit e23fd78

10 files changed

+21
-1
lines changed

core/src/main/java/org/apache/gravitino/listener/api/event/DeleteModelFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,13 @@
2020
package org.apache.gravitino.listener.api.event;
2121

2222
import org.apache.gravitino.NameIdentifier;
23+
import org.apache.gravitino.annotation.DeveloperApi;
2324

2425
/**
2526
* Represents an event that is generated when an attempt to drop a model from the schema fails due
2627
* to an exception.
2728
*/
29+
@DeveloperApi
2830
public class DeleteModelFailureEvent extends ModelFailureEvent {
2931
/**
3032
* Construct a new {@link DeleteModelFailureEvent} instance, capturing detailed information about

core/src/main/java/org/apache/gravitino/listener/api/event/DeleteModelVersionFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -21,11 +21,13 @@
2121

2222
import java.util.Optional;
2323
import org.apache.gravitino.NameIdentifier;
24+
import org.apache.gravitino.annotation.DeveloperApi;
2425

2526
/**
2627
* Represents an event that is generated when an attempt to delete a model version from a model
2728
* fails due to an exception.
2829
*/
30+
@DeveloperApi
2931
public class DeleteModelVersionFailureEvent extends ModelFailureEvent {
3032
private final Optional<String> alias;
3133
private final Optional<Integer> version;

core/src/main/java/org/apache/gravitino/listener/api/event/GetModelFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,12 @@
2020
package org.apache.gravitino.listener.api.event;
2121

2222
import org.apache.gravitino.NameIdentifier;
23+
import org.apache.gravitino.annotation.DeveloperApi;
2324

2425
/**
2526
* Represents an event that is generated when an attempt to get a model fails due to an exception.
2627
*/
28+
@DeveloperApi
2729
public class GetModelFailureEvent extends ModelFailureEvent {
2830
/**
2931
* Construct a new {@link GetModelFailureEvent} instance, capturing detailed information about the

core/src/main/java/org/apache/gravitino/listener/api/event/GetModelVersionFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -21,11 +21,13 @@
2121

2222
import java.util.Optional;
2323
import org.apache.gravitino.NameIdentifier;
24+
import org.apache.gravitino.annotation.DeveloperApi;
2425

2526
/**
2627
* Represents an event that is generated when an attempt to get a model version fails due to an
2728
* exception.
2829
*/
30+
@DeveloperApi
2931
public class GetModelVersionFailureEvent extends ModelFailureEvent {
3032
private final Optional<String> alias;
3133
private final Optional<Integer> version;

core/src/main/java/org/apache/gravitino/listener/api/event/LinkModelVersionFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,14 @@
2020
package org.apache.gravitino.listener.api.event;
2121

2222
import org.apache.gravitino.NameIdentifier;
23+
import org.apache.gravitino.annotation.DeveloperApi;
2324
import org.apache.gravitino.listener.api.info.ModelVersionInfo;
2425

2526
/**
2627
* Represents an event that is triggered when an attempt to link a model version fails due to an
2728
* exception.
2829
*/
30+
@DeveloperApi
2931
public class LinkModelVersionFailureEvent extends ModelFailureEvent {
3032
private final ModelVersionInfo linkModelVersionRequest;
3133
/**

core/src/main/java/org/apache/gravitino/listener/api/event/ListModelFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -21,11 +21,13 @@
2121

2222
import org.apache.gravitino.NameIdentifier;
2323
import org.apache.gravitino.Namespace;
24+
import org.apache.gravitino.annotation.DeveloperApi;
2425

2526
/**
2627
* Represents an event that is triggered when an attempt to list models within a namespace fails due
2728
* to an exception.
2829
*/
30+
@DeveloperApi
2931
public class ListModelFailureEvent extends ModelFailureEvent {
3032
private final Namespace namespace;
3133

core/src/main/java/org/apache/gravitino/listener/api/event/ListModelVersionFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,13 @@
2020
package org.apache.gravitino.listener.api.event;
2121

2222
import org.apache.gravitino.NameIdentifier;
23+
import org.apache.gravitino.annotation.DeveloperApi;
2324

2425
/**
2526
* Represents an event that is generated when an attempt to list versions of a model fails due to an
2627
* exception.
2728
*/
29+
@DeveloperApi
2830
public class ListModelVersionFailureEvent extends ModelFailureEvent {
2931

3032
/**

core/src/main/java/org/apache/gravitino/listener/api/event/ModelFailureEvent.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
package org.apache.gravitino.listener.api.event;
2121

2222
import org.apache.gravitino.NameIdentifier;
23+
import org.apache.gravitino.annotation.DeveloperApi;
2324

2425
/**
2526
* An abstract class representing events that are triggered when a model operation fails due to an
@@ -31,7 +32,8 @@
3132
* operations such as creating, updating, deleting, or querying tables, making it easier to diagnose
3233
* and respond to issues.
3334
*/
34-
public class ModelFailureEvent extends FailureEvent {
35+
@DeveloperApi
36+
public abstract class ModelFailureEvent extends FailureEvent {
3537

3638
/**
3739
* Creates a new instance of {@code ModelFailureEvent}, capturing information about the failed

core/src/main/java/org/apache/gravitino/listener/api/event/RegisterAndLinkModelFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -20,13 +20,15 @@
2020
package org.apache.gravitino.listener.api.event;
2121

2222
import org.apache.gravitino.NameIdentifier;
23+
import org.apache.gravitino.annotation.DeveloperApi;
2324
import org.apache.gravitino.listener.api.info.ModelInfo;
2425
import org.apache.gravitino.listener.api.info.ModelVersionInfo;
2526

2627
/**
2728
* Represents an event that is generated when an attempt to register a model or link a model version
2829
* of a model fails due to an exception.
2930
*/
31+
@DeveloperApi
3032
public class RegisterAndLinkModelFailureEvent extends ModelFailureEvent {
3133
private final ModelInfo registerModelRequest;
3234
private final ModelVersionInfo linkModelVersionRequest;

core/src/main/java/org/apache/gravitino/listener/api/event/RegisterModelFailureEvent.java

+2
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,14 @@
2020
package org.apache.gravitino.listener.api.event;
2121

2222
import org.apache.gravitino.NameIdentifier;
23+
import org.apache.gravitino.annotation.DeveloperApi;
2324
import org.apache.gravitino.listener.api.info.ModelInfo;
2425

2526
/**
2627
* Represents an event that is generated when an attempt to register a model fails due to an
2728
* exception.
2829
*/
30+
@DeveloperApi
2931
public class RegisterModelFailureEvent extends ModelFailureEvent {
3032
private final ModelInfo registerModelRequest;
3133
/**

0 commit comments

Comments
 (0)