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)
+ '}';