diff --git a/core/src/main/java/org/apache/gravitino/listener/TagEventDispatcher.java b/core/src/main/java/org/apache/gravitino/listener/TagEventDispatcher.java index 22d7718b571..8165b2f4ff7 100644 --- a/core/src/main/java/org/apache/gravitino/listener/TagEventDispatcher.java +++ b/core/src/main/java/org/apache/gravitino/listener/TagEventDispatcher.java @@ -19,9 +19,9 @@ package org.apache.gravitino.listener; import java.util.Map; - import org.apache.gravitino.MetadataObject; import org.apache.gravitino.exceptions.NoSuchTagException; +import org.apache.gravitino.listener.api.event.AlterTagEvent; import org.apache.gravitino.listener.api.event.AssociateTagsForMetadataObjectEvent; import org.apache.gravitino.listener.api.event.AlterTagFailureEvent; import org.apache.gravitino.listener.api.event.AssociateTagsForMetadataObjectFailureEvent; @@ -42,7 +42,6 @@ import org.apache.gravitino.listener.api.event.ListMetadataObjectsForTagEvent; import org.apache.gravitino.listener.api.event.ListTagEvent; import org.apache.gravitino.listener.api.event.ListTagInfoEvent; -import org.apache.gravitino.listener.api.event.AlterTagEvent; import org.apache.gravitino.listener.api.event.ListTagsForMetadataObjectEvent; import org.apache.gravitino.listener.api.event.ListTagsInfoForMetadataObjectEvent; import org.apache.gravitino.listener.api.info.TagInfo; @@ -58,13 +57,13 @@ * of tag operations. */ public class TagEventDispatcher implements TagDispatcher { - private final EventBus eventBus; - private final TagDispatcher dispatcher; + private final EventBus eventBus; + private final TagDispatcher dispatcher; - public TagEventDispatcher(EventBus eventBus, TagDispatcher dispatcher) { - this.eventBus = eventBus; - this.dispatcher = dispatcher; - } + public TagEventDispatcher(EventBus eventBus, TagDispatcher dispatcher) { + this.eventBus = eventBus; + this.dispatcher = dispatcher; + } @Override public String[] listTags(String metalake) { diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/AlterTagEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/AlterTagEvent.java index 7ad756b55bc..40942464f3f 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/AlterTagEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/AlterTagEvent.java @@ -20,64 +20,60 @@ package org.apache.gravitino.listener.api.event; import org.apache.gravitino.NameIdentifier; -import org.apache.gravitino.tag.TagChange; import org.apache.gravitino.annotation.DeveloperApi; import org.apache.gravitino.listener.api.info.TagInfo; +import org.apache.gravitino.tag.TagChange; /** Represents an event triggered upon the successful alteration of a tag. */ @DeveloperApi public final class AlterTagEvent extends TagEvent { - private final TagInfo updatedTagInfo; - private final TagChange[] tagChanges; + private final TagInfo updatedTagInfo; + private final TagChange[] tagChanges; - /** - * Constructs an instance of {@code AlterTagEvent}, encapsulating the key details about the - * successful alteration of a tag. - * - * @param user The username of the individual responsible for initiating the tag alteration. - * @param metalake The metalake from which the tag is being altered. - * @param tagChanges An array of {@link TagChange} objects representing the specific - * changes applied to the tag during the alteration process. - * @param updatedTagInfo The post-alteration state of the tag. - */ - public AlterTagEvent( - String user, - String metalake, - TagChange[] tagChanges, - TagInfo updatedTagInfo) { - super(user, NameIdentifier.of(metalake)); - this.tagChanges = tagChanges.clone(); - this.updatedTagInfo = updatedTagInfo; - } + /** + * Constructs an instance of {@code AlterTagEvent}, encapsulating the key details about the + * successful alteration of a tag. + * + * @param user The username of the individual responsible for initiating the tag alteration. + * @param metalake The metalake from which the tag is being altered. + * @param tagChanges An array of {@link TagChange} objects representing the specific changes + * applied to the tag during the alteration process. + * @param updatedTagInfo The post-alteration state of the tag. + */ + public AlterTagEvent( + String user, String metalake, TagChange[] tagChanges, TagInfo updatedTagInfo) { + super(user, NameIdentifier.of(metalake)); + this.tagChanges = tagChanges.clone(); + this.updatedTagInfo = updatedTagInfo; + } - /** - * Retrieves the final state of the tag as it was returned to the user after successful - * alteration. - * - * @return A {@link TagInfo} instance encapsulating the comprehensive details of the newly - * altered tag. - */ - public TagInfo updatedTagInfo() { - return updatedTagInfo; - } + /** + * Retrieves the final state of the tag as it was returned to the user after successful + * alteration. + * + * @return A {@link TagInfo} instance encapsulating the comprehensive details of the newly altered + * tag. + */ + public TagInfo updatedTagInfo() { + return updatedTagInfo; + } - /** - * Retrieves the specific changes that were made to the tag during the alteration process. - * - * @return An array of {@link TagChange} objects detailing each modification applied to the - * tag. - */ - public TagChange[] tagChanges() { - return tagChanges; - } + /** + * Retrieves the specific changes that were made to the tag during the alteration process. + * + * @return An array of {@link TagChange} objects detailing each modification applied to the tag. + */ + public TagChange[] tagChanges() { + return tagChanges; + } - /** - * Returns the type of operation. - * - * @return the operation type. - */ - @Override - public OperationType operationType() { - return OperationType.ALTER_TAG; - } + /** + * Returns the type of operation. + * + * @return the operation type. + */ + @Override + public OperationType operationType() { + return OperationType.ALTER_TAG; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/AssociateTagsForMetadataObjectEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/AssociateTagsForMetadataObjectEvent.java index b2628c7f360..bd99533f2e5 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/AssociateTagsForMetadataObjectEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/AssociateTagsForMetadataObjectEvent.java @@ -19,90 +19,98 @@ package org.apache.gravitino.listener.api.event; +import org.apache.gravitino.MetadataObject; import org.apache.gravitino.NameIdentifier; import org.apache.gravitino.annotation.DeveloperApi; -import org.apache.gravitino.MetadataObject; -/** Represents an event that is triggered upon successfully associating tags with a metadata object. */ +/** + * Represents an event that is triggered upon successfully associating tags with a metadata object. + */ @DeveloperApi public final class AssociateTagsForMetadataObjectEvent extends TagEvent { - private final String metalake; - private final MetadataObject metadataObject; - private final String[] tagsToAdd; - private final String[] tagsToRemove; - private final String[] associatedTags; + private final String metalake; + private final MetadataObject metadataObject; + private final String[] tagsToAdd; + private final String[] tagsToRemove; + private final String[] associatedTags; - /** - * Constructs an instance of {@code AssociateTagsForMetadataObjectEvent}. - * - * @param user The username of the individual who initiated the tag association. - * @param metalake The metalake from which the tags were associated. - * @param metadataObject The metadata object with which the tags were associated. - * @param tagsToAdd The tags that were added. - * @param tagsToRemove The tags that were removed. - * @param associatedTags The resulting list of associated tags after the operation. - */ - public AssociateTagsForMetadataObjectEvent(String user, String metalake, MetadataObject metadataObject, String[] tagsToAdd, String[] tagsToRemove, String[] associatedTags) { - super(user, NameIdentifier.of(metalake)); - this.metalake = metalake; - this.metadataObject = metadataObject; - this.tagsToAdd = tagsToAdd; - this.tagsToRemove = tagsToRemove; - this.associatedTags = associatedTags; - } + /** + * Constructs an instance of {@code AssociateTagsForMetadataObjectEvent}. + * + * @param user The username of the individual who initiated the tag association. + * @param metalake The metalake from which the tags were associated. + * @param metadataObject The metadata object with which the tags were associated. + * @param tagsToAdd The tags that were added. + * @param tagsToRemove The tags that were removed. + * @param associatedTags The resulting list of associated tags after the operation. + */ + public AssociateTagsForMetadataObjectEvent( + String user, + String metalake, + MetadataObject metadataObject, + String[] tagsToAdd, + String[] tagsToRemove, + String[] associatedTags) { + super(user, NameIdentifier.of(metalake)); + this.metalake = metalake; + this.metadataObject = metadataObject; + this.tagsToAdd = tagsToAdd; + this.tagsToRemove = tagsToRemove; + this.associatedTags = associatedTags; + } - /** - * Provides the metalake associated with this event. - * - * @return The metalake from which the tags were associated. - */ - public String metalake() { - return metalake; - } + /** + * Provides the metalake associated with this event. + * + * @return The metalake from which the tags were associated. + */ + public String metalake() { + return metalake; + } - /** - * Provides the metadata object associated with this event. - * - * @return The {@link MetadataObject} with which the tags were associated. - */ - public MetadataObject metadataObject() { - return metadataObject; - } + /** + * Provides the metadata object associated with this event. + * + * @return The {@link MetadataObject} with which the tags were associated. + */ + public MetadataObject metadataObject() { + return metadataObject; + } - /** - * Provides the tags that were added in this operation. - * - * @return An array of tag names that were added. - */ - public String[] tagsToAdd() { - return tagsToAdd; - } + /** + * Provides the tags that were added in this operation. + * + * @return An array of tag names that were added. + */ + public String[] tagsToAdd() { + return tagsToAdd; + } - /** - * Provides the tags that were removed in this operation. - * - * @return An array of tag names that were removed. - */ - public String[] tagsToRemove() { - return tagsToRemove; - } + /** + * Provides the tags that were removed in this operation. + * + * @return An array of tag names that were removed. + */ + public String[] tagsToRemove() { + return tagsToRemove; + } - /** - * Provides the resulting list of associated tags after the operation. - * - * @return An array of tag names representing the associated tags. - */ - public String[] associatedTags() { - return associatedTags; - } + /** + * Provides the resulting list of associated tags after the operation. + * + * @return An array of tag names representing the associated tags. + */ + public String[] associatedTags() { + return associatedTags; + } - /** - * Returns the type of operation. - * - * @return The operation type. - */ - @Override - public OperationType operationType() { - return OperationType.ASSOCIATE_TAGS_FOR_METADATA_OBJECT; - } + /** + * Returns the type of operation. + * + * @return The operation type. + */ + @Override + public OperationType operationType() { + return OperationType.ASSOCIATE_TAGS_FOR_METADATA_OBJECT; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/CreateTagEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/CreateTagEvent.java index c641d338880..f6e9d0deeb8 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/CreateTagEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/CreateTagEvent.java @@ -23,45 +23,42 @@ import org.apache.gravitino.annotation.DeveloperApi; import org.apache.gravitino.listener.api.info.TagInfo; -/** - * Represents an event that is activated upon the successful creation of a tag. - */ +/** Represents an event that is activated upon the successful creation of a tag. */ @DeveloperApi public final class CreateTagEvent extends TagEvent { - private final TagInfo createdTagInfo; + private final TagInfo createdTagInfo; - /** - * Constructs an instance of {@code CreateTagEvent}, capturing essential details about the - * successful creation of a tag. - * - * @param user The username of the individual who initiated the tag creation. - * @param metalake The metalake from which the tag was created. - * @param createdTagInfo The final state of the tag post-creation. - */ - public CreateTagEvent(String user, String metalake, TagInfo createdTagInfo) { - super(user, NameIdentifier.of(metalake)); - this.createdTagInfo = createdTagInfo; - } + /** + * Constructs an instance of {@code CreateTagEvent}, capturing essential details about the + * successful creation of a tag. + * + * @param user The username of the individual who initiated the tag creation. + * @param metalake The metalake from which the tag was created. + * @param createdTagInfo The final state of the tag post-creation. + */ + public CreateTagEvent(String user, String metalake, TagInfo createdTagInfo) { + super(user, NameIdentifier.of(metalake)); + this.createdTagInfo = createdTagInfo; + } - /** - * Provides the final state of the tag as it is presented to the user following the successful - * creation. - * - * @return A {@link TagInfo} object that encapsulates the detailed characteristics of the - * newly created tag. - */ - public TagInfo createdTagInfo() { - return createdTagInfo; - } + /** + * Provides the final state of the tag as it is presented to the user following the successful + * creation. + * + * @return A {@link TagInfo} object that encapsulates the detailed characteristics of the newly + * created tag. + */ + public TagInfo createdTagInfo() { + return createdTagInfo; + } - /** - * Returns the type of operation. - * - * @return The operation type. - */ - @Override - public OperationType operationType() { - return OperationType.CREATE_TAG; - } + /** + * Returns the type of operation. + * + * @return The operation type. + */ + @Override + public OperationType operationType() { + return OperationType.CREATE_TAG; + } } - diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/DeleteTagEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/DeleteTagEvent.java index ddfcf08f638..2ea84445970 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/DeleteTagEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/DeleteTagEvent.java @@ -25,39 +25,39 @@ /** Represents an event that is generated after a tag is successfully deleted. */ @DeveloperApi public final class DeleteTagEvent extends TagEvent { - private final boolean isExists; + private final boolean isExists; - /** - * Constructs a new {@code DeleteTagEvent} instance, encapsulating information about the outcome - * of a tag delete operation. - * - * @param user The user who initiated the delete tag operation. - * @param metalake The metalake from which the tag was deleted. - * @param isExists A boolean flag indicating whether the tag existed at the time of the delete - * operation. - */ - public DeleteTagEvent(String user, String metalake, boolean isExists) { - super(user, NameIdentifier.of(metalake)); - this.isExists = isExists; - } + /** + * Constructs a new {@code DeleteTagEvent} instance, encapsulating information about the outcome + * of a tag delete operation. + * + * @param user The user who initiated the delete tag operation. + * @param metalake The metalake from which the tag was deleted. + * @param isExists A boolean flag indicating whether the tag existed at the time of the delete + * operation. + */ + public DeleteTagEvent(String user, String metalake, boolean isExists) { + super(user, NameIdentifier.of(metalake)); + this.isExists = isExists; + } - /** - * Retrieves the existence status of the tag at the time of the delete operation. - * - * @return A boolean value indicating whether the tag existed. {@code true} if the tag - * existed, otherwise {@code false}. - */ - public boolean isExists() { - return isExists; - } + /** + * Retrieves the existence status of the tag at the time of the delete operation. + * + * @return A boolean value indicating whether the tag existed. {@code true} if the tag existed, + * otherwise {@code false}. + */ + public boolean isExists() { + return isExists; + } - /** - * Returns the type of operation. - * - * @return the operation type. - */ - @Override - public OperationType operationType() { - return OperationType.DELETE_TAG; - } + /** + * Returns the type of operation. + * + * @return the operation type. + */ + @Override + public OperationType operationType() { + return OperationType.DELETE_TAG; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagEvent.java index ff977af049d..a95a01817ab 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagEvent.java @@ -26,59 +26,59 @@ /** Represents an event that is triggered upon successfully retrieving a tag. */ @DeveloperApi public final class GetTagEvent extends TagEvent { - private final String metalake; - private final String tagName; - private final Tag tag; + private final String metalake; + private final String tagName; + private final Tag tag; - /** - * Constructs an instance of {@code GetTagEvent}. - * - * @param user The username of the individual who initiated the tag retrieval. - * @param metalake The metalake from which the tag was retrieved. - * @param tagName The name of the tag being retrieved. - * @param tag The {@link Tag} object representing the retrieved tag. - */ - public GetTagEvent(String user, String metalake, String tagName, Tag tag) { - super(user, NameIdentifier.of(metalake)); - this.metalake = metalake; - this.tagName = tagName; - this.tag = tag; - } + /** + * Constructs an instance of {@code GetTagEvent}. + * + * @param user The username of the individual who initiated the tag retrieval. + * @param metalake The metalake from which the tag was retrieved. + * @param tagName The name of the tag being retrieved. + * @param tag The {@link Tag} object representing the retrieved tag. + */ + public GetTagEvent(String user, String metalake, String tagName, Tag tag) { + super(user, NameIdentifier.of(metalake)); + this.metalake = metalake; + this.tagName = tagName; + this.tag = tag; + } - /** - * Provides the metalake associated with this event. - * - * @return The metalake from which the tag was retrieved. - */ - public String metalake() { - return metalake; - } + /** + * Provides the metalake associated with this event. + * + * @return The metalake from which the tag was retrieved. + */ + public String metalake() { + return metalake; + } - /** - * Provides the name of the retrieved tag. - * - * @return The name of the tag. - */ - public String tagName() { - return tagName; - } + /** + * Provides the name of the retrieved tag. + * + * @return The name of the tag. + */ + public String tagName() { + return tagName; + } - /** - * Provides the retrieved tag object. - * - * @return The {@link Tag} object. - */ - public Tag tag() { - return tag; - } + /** + * Provides the retrieved tag object. + * + * @return The {@link Tag} object. + */ + public Tag tag() { + return tag; + } - /** - * Returns the type of operation. - * - * @return The operation type. - */ - @Override - public OperationType operationType() { - return OperationType.GET_TAG; - } + /** + * Returns the type of operation. + * + * @return The operation type. + */ + @Override + public OperationType operationType() { + return OperationType.GET_TAG; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagForMetadataObjectEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagForMetadataObjectEvent.java index d40ce1976e5..38723d038ea 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagForMetadataObjectEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/GetTagForMetadataObjectEvent.java @@ -19,79 +19,82 @@ package org.apache.gravitino.listener.api.event; +import org.apache.gravitino.MetadataObject; import org.apache.gravitino.NameIdentifier; import org.apache.gravitino.annotation.DeveloperApi; -import org.apache.gravitino.MetadataObject; import org.apache.gravitino.tag.Tag; -/** Represents an event that is triggered upon successfully retrieving a tag for a metadata object. */ +/** + * Represents an event that is triggered upon successfully retrieving a tag for a metadata object. + */ @DeveloperApi public final class GetTagForMetadataObjectEvent extends TagEvent { - private final String metalake; - private final MetadataObject metadataObject; - private final String tagName; - private final Tag tag; + private final String metalake; + private final MetadataObject metadataObject; + private final String tagName; + private final Tag tag; - /** - * Constructs an instance of {@code GetTagForMetadataObjectEvent}. - * - * @param user The username of the individual who initiated the tag retrieval. - * @param metalake The metalake from which the tag was retrieved. - * @param metadataObject The metadata object for which the tag was retrieved. - * @param tagName The name of the tag being retrieved. - * @param tag The {@link Tag} object representing the retrieved tag. - */ - public GetTagForMetadataObjectEvent(String user, String metalake, MetadataObject metadataObject, String tagName, Tag tag) { - super(user, NameIdentifier.of(metalake)); - this.metalake = metalake; - this.metadataObject = metadataObject; - this.tagName = tagName; - this.tag = tag; - } + /** + * Constructs an instance of {@code GetTagForMetadataObjectEvent}. + * + * @param user The username of the individual who initiated the tag retrieval. + * @param metalake The metalake from which the tag was retrieved. + * @param metadataObject The metadata object for which the tag was retrieved. + * @param tagName The name of the tag being retrieved. + * @param tag The {@link Tag} object representing the retrieved tag. + */ + public GetTagForMetadataObjectEvent( + String user, String metalake, MetadataObject metadataObject, String tagName, Tag tag) { + super(user, NameIdentifier.of(metalake)); + this.metalake = metalake; + this.metadataObject = metadataObject; + this.tagName = tagName; + this.tag = tag; + } - /** - * Provides the metalake associated with this event. - * - * @return The metalake from which the tag was retrieved. - */ - public String metalake() { - return metalake; - } + /** + * Provides the metalake associated with this event. + * + * @return The metalake from which the tag was retrieved. + */ + public String metalake() { + return metalake; + } - /** - * Provides the metadata object associated with this event. - * - * @return The {@link MetadataObject} for which the tag was retrieved. - */ - public MetadataObject metadataObject() { - return metadataObject; - } + /** + * Provides the metadata object associated with this event. + * + * @return The {@link MetadataObject} for which the tag was retrieved. + */ + public MetadataObject metadataObject() { + return metadataObject; + } - /** - * Provides the name of the retrieved tag. - * - * @return The name of the tag. - */ - public String tagName() { - return tagName; - } + /** + * Provides the name of the retrieved tag. + * + * @return The name of the tag. + */ + public String tagName() { + return tagName; + } - /** - * Provides the retrieved tag object. - * - * @return The {@link Tag} object. - */ - public Tag tag() { - return tag; - } + /** + * Provides the retrieved tag object. + * + * @return The {@link Tag} object. + */ + public Tag tag() { + return tag; + } - /** - * Returns the type of operation. - * - * @return The operation type. - */ - @Override - public OperationType operationType() { - return OperationType.GET_TAG_FOR_METADATA_OBJECT; - } + /** + * Returns the type of operation. + * + * @return The operation type. + */ + @Override + public OperationType operationType() { + return OperationType.GET_TAG_FOR_METADATA_OBJECT; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/ListMetadataObjectsForTagEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/ListMetadataObjectsForTagEvent.java index 106a1f7ef43..d081a366b4f 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/ListMetadataObjectsForTagEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/ListMetadataObjectsForTagEvent.java @@ -19,66 +19,68 @@ package org.apache.gravitino.listener.api.event; +import org.apache.gravitino.MetadataObject; import org.apache.gravitino.NameIdentifier; import org.apache.gravitino.annotation.DeveloperApi; -import org.apache.gravitino.MetadataObject; /** Represents an event that is triggered upon successfully listing metadata objects for a tag. */ @DeveloperApi public final class ListMetadataObjectsForTagEvent extends TagEvent { - private final String metalake; - private final String tagName; - private final MetadataObject[] metadataObjects; + private final String metalake; + private final String tagName; + private final MetadataObject[] metadataObjects; - /** - * Constructs an instance of {@code ListMetadataObjectsForTagEvent}. - * - * @param user The username of the individual who initiated the metadata objects listing. - * @param metalake The metalake from which metadata objects were listed. - * @param tagName The name of the tag for which metadata objects were listed. - * @param metadataObjects An array of {@link MetadataObject} representing the listed metadata objects. - */ - public ListMetadataObjectsForTagEvent(String user, String metalake, String tagName, MetadataObject[] metadataObjects) { - super(user, NameIdentifier.of(metalake)); - this.metalake = metalake; - this.tagName = tagName; - this.metadataObjects = metadataObjects; - } + /** + * Constructs an instance of {@code ListMetadataObjectsForTagEvent}. + * + * @param user The username of the individual who initiated the metadata objects listing. + * @param metalake The metalake from which metadata objects were listed. + * @param tagName The name of the tag for which metadata objects were listed. + * @param metadataObjects An array of {@link MetadataObject} representing the listed metadata + * objects. + */ + public ListMetadataObjectsForTagEvent( + String user, String metalake, String tagName, MetadataObject[] metadataObjects) { + super(user, NameIdentifier.of(metalake)); + this.metalake = metalake; + this.tagName = tagName; + this.metadataObjects = metadataObjects; + } - /** - * Provides the metalake associated with this event. - * - * @return The metalake from which metadata objects were listed. - */ - public String metalake() { - return metalake; - } + /** + * Provides the metalake associated with this event. + * + * @return The metalake from which metadata objects were listed. + */ + public String metalake() { + return metalake; + } - /** - * Provides the name of the tag associated with this event. - * - * @return The name of the tag. - */ - public String tagName() { - return tagName; - } + /** + * Provides the name of the tag associated with this event. + * + * @return The name of the tag. + */ + public String tagName() { + return tagName; + } - /** - * Provides the metadata objects associated with this event. - * - * @return An array of {@link MetadataObject}. - */ - public MetadataObject[] metadataObjects() { - return metadataObjects; - } + /** + * Provides the metadata objects associated with this event. + * + * @return An array of {@link MetadataObject}. + */ + public MetadataObject[] metadataObjects() { + return metadataObjects; + } - /** - * Returns the type of operation. - * - * @return The operation type. - */ - @Override - public OperationType operationType() { - return OperationType.LIST_METADATA_OBJECTS_FOR_TAG; - } + /** + * Returns the type of operation. + * + * @return The operation type. + */ + @Override + public OperationType operationType() { + return OperationType.LIST_METADATA_OBJECTS_FOR_TAG; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagEvent.java index 741b5bfbace..6b4000e5ee2 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagEvent.java @@ -25,35 +25,35 @@ /** Represents an event that is triggered upon the successful listing of tags. */ @DeveloperApi public final class ListTagEvent extends TagEvent { - private final String metalake; + private final String metalake; - /** - * Constructs an instance of {@code ListTagEvent}. - * - * @param user The username of the individual who initiated the tag listing. - * @param metalake The namespace from which tags were listed. - */ - public ListTagEvent(String user, String metalake) { - super(user, NameIdentifier.of(metalake)); - this.metalake = metalake; - } + /** + * Constructs an instance of {@code ListTagEvent}. + * + * @param user The username of the individual who initiated the tag listing. + * @param metalake The namespace from which tags were listed. + */ + public ListTagEvent(String user, String metalake) { + super(user, NameIdentifier.of(metalake)); + this.metalake = metalake; + } - /** - * Provides the metalake associated with this event. - * - * @return The metalake from which tags were listed. - */ - public String metalake() { - return metalake; - } + /** + * Provides the metalake associated with this event. + * + * @return The metalake from which tags were listed. + */ + public String metalake() { + return metalake; + } - /** - * Returns the type of operation. - * - * @return the operation type. - */ - @Override - public OperationType operationType() { - return OperationType.LIST_TAG; - } -} \ No newline at end of file + /** + * Returns the type of operation. + * + * @return the operation type. + */ + @Override + public OperationType operationType() { + return OperationType.LIST_TAG; + } +} diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagInfoEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagInfoEvent.java index 22107bca0ca..1e70d9f7622 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagInfoEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagInfoEvent.java @@ -26,36 +26,36 @@ /** Represents an event that is triggered upon the successful listing of tags. */ @DeveloperApi public final class ListTagInfoEvent extends TagEvent { - private final Tag[] tags; + private final Tag[] tags; - /** - * Constructs an instance of {@code ListTagsEvent}. - * - * @param user The username of the individual who initiated the tag listing. - * @param metalake The namespace from which tags were listed. - * @param tags An array of {@link Tag} objects representing the tags. - */ - public ListTagInfoEvent(String user, String metalake, Tag[] tags) { - super(user, NameIdentifier.of(metalake)); - this.tags = tags; - } + /** + * Constructs an instance of {@code ListTagsEvent}. + * + * @param user The username of the individual who initiated the tag listing. + * @param metalake The namespace from which tags were listed. + * @param tags An array of {@link Tag} objects representing the tags. + */ + public ListTagInfoEvent(String user, String metalake, Tag[] tags) { + super(user, NameIdentifier.of(metalake)); + this.tags = tags; + } - /** - * Provides the tags associated with this event. - * - * @return An array of {@link Tag} objects. - */ - public Tag[] tags() { - return tags; - } + /** + * Provides the tags associated with this event. + * + * @return An array of {@link Tag} objects. + */ + public Tag[] tags() { + return tags; + } - /** - * Returns the type of operation. - * - * @return the operation type. - */ - @Override - public OperationType operationType() { - return OperationType.LISTINFO_TAG; - } + /** + * Returns the type of operation. + * + * @return the operation type. + */ + @Override + public OperationType operationType() { + return OperationType.LISTINFO_TAG; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsForMetadataObjectEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsForMetadataObjectEvent.java index 6591c824da7..60432af8c89 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsForMetadataObjectEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsForMetadataObjectEvent.java @@ -19,66 +19,67 @@ package org.apache.gravitino.listener.api.event; +import org.apache.gravitino.MetadataObject; import org.apache.gravitino.NameIdentifier; import org.apache.gravitino.annotation.DeveloperApi; -import org.apache.gravitino.MetadataObject; /** Represents an event that is triggered upon successfully listing tags for a metadata object. */ @DeveloperApi public final class ListTagsForMetadataObjectEvent extends TagEvent { - private final String metalake; - private final MetadataObject metadataObject; - private final String[] tags; + private final String metalake; + private final MetadataObject metadataObject; + private final String[] tags; - /** - * Constructs an instance of {@code ListTagsForMetadataObjectEvent}. - * - * @param user The username of the individual who initiated the tag listing. - * @param metalake The metalake from which tags were listed. - * @param metadataObject The metadata object for which tags were listed. - * @param tags An array of tag names representing the tags listed for the metadata object. - */ - public ListTagsForMetadataObjectEvent(String user, String metalake, MetadataObject metadataObject, String[] tags) { - super(user, NameIdentifier.of(metalake)); - this.metalake = metalake; - this.metadataObject = metadataObject; - this.tags = tags; - } + /** + * Constructs an instance of {@code ListTagsForMetadataObjectEvent}. + * + * @param user The username of the individual who initiated the tag listing. + * @param metalake The metalake from which tags were listed. + * @param metadataObject The metadata object for which tags were listed. + * @param tags An array of tag names representing the tags listed for the metadata object. + */ + public ListTagsForMetadataObjectEvent( + String user, String metalake, MetadataObject metadataObject, String[] tags) { + super(user, NameIdentifier.of(metalake)); + this.metalake = metalake; + this.metadataObject = metadataObject; + this.tags = tags; + } - /** - * Provides the metalake associated with this event. - * - * @return The metalake from which tags were listed. - */ - public String metalake() { - return metalake; - } + /** + * Provides the metalake associated with this event. + * + * @return The metalake from which tags were listed. + */ + public String metalake() { + return metalake; + } - /** - * Provides the metadata object associated with this event. - * - * @return The {@link MetadataObject} for which tags were listed. - */ - public MetadataObject metadataObject() { - return metadataObject; - } + /** + * Provides the metadata object associated with this event. + * + * @return The {@link MetadataObject} for which tags were listed. + */ + public MetadataObject metadataObject() { + return metadataObject; + } - /** - * Provides the tags associated with this event. - * - * @return An array of tag names. - */ - public String[] tags() { - return tags; - } + /** + * Provides the tags associated with this event. + * + * @return An array of tag names. + */ + public String[] tags() { + return tags; + } - /** - * Returns the type of operation. - * - * @return The operation type. - */ - @Override - public OperationType operationType() { - return OperationType.LIST_TAGS_FOR_METADATA_OBJECT; - } + /** + * Returns the type of operation. + * + * @return The operation type. + */ + @Override + public OperationType operationType() { + return OperationType.LIST_TAGS_FOR_METADATA_OBJECT; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsInfoForMetadataObjectEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsInfoForMetadataObjectEvent.java index 634a6278700..f5bebe57937 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsInfoForMetadataObjectEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/ListTagsInfoForMetadataObjectEvent.java @@ -19,67 +19,71 @@ package org.apache.gravitino.listener.api.event; +import org.apache.gravitino.MetadataObject; import org.apache.gravitino.NameIdentifier; import org.apache.gravitino.annotation.DeveloperApi; -import org.apache.gravitino.MetadataObject; import org.apache.gravitino.tag.Tag; -/** Represents an event that is triggered upon successfully listing detailed tag information for a metadata object. */ +/** + * Represents an event that is triggered upon successfully listing detailed tag information for a + * metadata object. + */ @DeveloperApi public final class ListTagsInfoForMetadataObjectEvent extends TagEvent { - private final String metalake; - private final MetadataObject metadataObject; - private final Tag[] tags; + private final String metalake; + private final MetadataObject metadataObject; + private final Tag[] tags; - /** - * Constructs an instance of {@code ListTagsInfoForMetadataObjectEvent}. - * - * @param user The username of the individual who initiated the tag information listing. - * @param metalake The metalake from which tag information was listed. - * @param metadataObject The metadata object for which tag information was listed. - * @param tags An array of {@link Tag} objects representing the detailed tag information. - */ - public ListTagsInfoForMetadataObjectEvent(String user, String metalake, MetadataObject metadataObject, Tag[] tags) { - super(user, NameIdentifier.of(metalake)); - this.metalake = metalake; - this.metadataObject = metadataObject; - this.tags = tags; - } + /** + * Constructs an instance of {@code ListTagsInfoForMetadataObjectEvent}. + * + * @param user The username of the individual who initiated the tag information listing. + * @param metalake The metalake from which tag information was listed. + * @param metadataObject The metadata object for which tag information was listed. + * @param tags An array of {@link Tag} objects representing the detailed tag information. + */ + public ListTagsInfoForMetadataObjectEvent( + String user, String metalake, MetadataObject metadataObject, Tag[] tags) { + super(user, NameIdentifier.of(metalake)); + this.metalake = metalake; + this.metadataObject = metadataObject; + this.tags = tags; + } - /** - * Provides the metalake associated with this event. - * - * @return The metalake from which tag information was listed. - */ - public String metalake() { - return metalake; - } + /** + * Provides the metalake associated with this event. + * + * @return The metalake from which tag information was listed. + */ + public String metalake() { + return metalake; + } - /** - * Provides the metadata object associated with this event. - * - * @return The {@link MetadataObject} for which tag information was listed. - */ - public MetadataObject metadataObject() { - return metadataObject; - } + /** + * Provides the metadata object associated with this event. + * + * @return The {@link MetadataObject} for which tag information was listed. + */ + public MetadataObject metadataObject() { + return metadataObject; + } - /** - * Provides the detailed tag information associated with this event. - * - * @return An array of {@link Tag} objects. - */ - public Tag[] tags() { - return tags; - } + /** + * Provides the detailed tag information associated with this event. + * + * @return An array of {@link Tag} objects. + */ + public Tag[] tags() { + return tags; + } - /** - * Returns the type of operation. - * - * @return The operation type. - */ - @Override - public OperationType operationType() { - return OperationType.LIST_TAGS_INFO_FOR_METADATA_OBJECT; - } + /** + * Returns the type of operation. + * + * @return The operation type. + */ + @Override + public OperationType operationType() { + return OperationType.LIST_TAGS_INFO_FOR_METADATA_OBJECT; + } } diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/OperationType.java b/core/src/main/java/org/apache/gravitino/listener/api/event/OperationType.java index b014398749a..1dccc94a82d 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/OperationType.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/OperationType.java @@ -99,7 +99,7 @@ public enum OperationType { RENAME_VIEW, LIST_VIEW, - //Tag event + // Tag event CREATE_TAG, ALTER_TAG, LIST_TAG, diff --git a/core/src/main/java/org/apache/gravitino/listener/api/event/TagEvent.java b/core/src/main/java/org/apache/gravitino/listener/api/event/TagEvent.java index 4b2af357262..e7f59ca9881 100644 --- a/core/src/main/java/org/apache/gravitino/listener/api/event/TagEvent.java +++ b/core/src/main/java/org/apache/gravitino/listener/api/event/TagEvent.java @@ -23,24 +23,24 @@ import org.apache.gravitino.annotation.DeveloperApi; /** - * Represents an abstract base class for events related to tag operations. - * This class extends {@link Event} to provide a more specific context - * involving operations on tags, such as creation, deletion, or modification. + * Represents an abstract base class for events related to tag operations. This class extends {@link + * Event} to provide a more specific context involving operations on tags, such as creation, + * deletion, or modification. */ @DeveloperApi public abstract class TagEvent extends Event { - /** - * Constructs a new {@code TagEvent} with the specified user and tag identifier. - * - * @param user The user responsible for triggering the tag operation. - * @param identifier The identifier of the tag involved in the operation. - */ - protected TagEvent(String user, NameIdentifier identifier) { - super(user, identifier); - } + /** + * Constructs a new {@code TagEvent} with the specified user and tag identifier. + * + * @param user The user responsible for triggering the tag operation. + * @param identifier The identifier of the tag involved in the operation. + */ + protected TagEvent(String user, NameIdentifier identifier) { + super(user, identifier); + } - @Override - public OperationStatus operationStatus() { - return OperationStatus.SUCCESS; - } + @Override + public OperationStatus operationStatus() { + return OperationStatus.SUCCESS; + } }