This is an automated email from the ASF dual-hosted git repository.

wuchunfu pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 7e77384305 [Core][Flink] optimize method name (#7372)
7e77384305 is described below

commit 7e77384305df100b0967405aa1b04c4d5a7fedce
Author: Tyrantlucifer <[email protected]>
AuthorDate: Tue Aug 13 09:38:53 2024 +0800

    [Core][Flink] optimize method name (#7372)
---
 .../seatunnel/api/table/type/SeaTunnelRow.java     | 29 ++++++----------------
 1 file changed, 7 insertions(+), 22 deletions(-)

diff --git 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java
 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java
index 11388dbb6a..5f9f05c952 100644
--- 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java
+++ 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java
@@ -28,7 +28,7 @@ public final class SeaTunnelRow implements Serializable {
     /** Table identifier. */
     private String tableId = "";
     /** The kind of change that a row describes in a changelog. */
-    private RowKind kind = RowKind.INSERT;
+    private RowKind rowKind = RowKind.INSERT;
     /** The array to store the actual internal format values. */
     private final Object[] fields;
 
@@ -50,17 +50,8 @@ public final class SeaTunnelRow implements Serializable {
         this.tableId = tableId;
     }
 
-    /**
-     * The method will be removed in the future, please use {@link 
#setKind(RowKind)} instanced of
-     * it.
-     */
-    @Deprecated
-    public void setRowKind(RowKind kind) {
-        setKind(kind);
-    }
-
-    public void setKind(RowKind kind) {
-        this.kind = kind;
+    public void setRowKind(RowKind rowKind) {
+        this.rowKind = rowKind;
     }
 
     public int getArity() {
@@ -71,14 +62,8 @@ public final class SeaTunnelRow implements Serializable {
         return tableId;
     }
 
-    /** The method will be removed in the future, please use {@link 
#getKind()} instanced of it. */
-    @Deprecated
     public RowKind getRowKind() {
-        return getKind();
-    }
-
-    public RowKind getKind() {
-        return this.kind;
+        return this.rowKind;
     }
 
     public Object[] getFields() {
@@ -335,13 +320,13 @@ public final class SeaTunnelRow implements Serializable {
         }
         SeaTunnelRow that = (SeaTunnelRow) o;
         return Objects.equals(tableId, that.tableId)
-                && kind == that.kind
+                && rowKind == that.rowKind
                 && Arrays.deepEquals(fields, that.fields);
     }
 
     @Override
     public int hashCode() {
-        int result = Objects.hash(tableId, kind);
+        int result = Objects.hash(tableId, rowKind);
         result = 31 * result + Arrays.deepHashCode(fields);
         return result;
     }
@@ -352,7 +337,7 @@ public final class SeaTunnelRow implements Serializable {
                 + "tableId="
                 + tableId
                 + ", kind="
-                + kind.shortString()
+                + rowKind.shortString()
                 + ", fields="
                 + Arrays.toString(fields)
                 + '}';

Reply via email to