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 11388dbb6a7..5f9f05c9528 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 void setTableId(String tableId) { 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 String getTableId() { 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 boolean equals(Object o) { } 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 String toString() { + "tableId=" + tableId + ", kind=" - + kind.shortString() + + rowKind.shortString() + ", fields=" + Arrays.toString(fields) + '}';