rename vtts

apache · Oct 27, 2023 · 8b5d469 · 8b5d469
1 parent 2b376f2
commit 8b5d469
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 18 deletions.
diff --git a/...connect-events/src/main/java/org/apache/iceberg/connect/events/CommitCompletePayload.java b/...connect-events/src/main/java/org/apache/iceberg/connect/events/CommitCompletePayload.java
@@ -31,7 +31,7 @@
 public class CommitCompletePayload implements Payload {
 
   private UUID commitId;
-  private Long vtts;
+  private Long validThroughTs;
   private final Schema avroSchema;
 
   private static final Schema AVRO_SCHEMA =
@@ -42,7 +42,7 @@ public class CommitCompletePayload implements Payload {
           .prop(AvroSchemaUtil.FIELD_ID_PROP, 1000)
           .type(UUID_SCHEMA)
           .noDefault()
-          .name("vtts")
+          .name("validThroughTs")
           .prop(AvroSchemaUtil.FIELD_ID_PROP, 1001)
           .type()
           .nullable()
@@ -55,9 +55,9 @@ public CommitCompletePayload(Schema avroSchema) {
     this.avroSchema = avroSchema;
   }
 
-  public CommitCompletePayload(UUID commitId, Long vtts) {
+  public CommitCompletePayload(UUID commitId, Long validThroughTs) {
     this.commitId = commitId;
-    this.vtts = vtts;
+    this.validThroughTs = validThroughTs;
     this.avroSchema = AVRO_SCHEMA;
   }
 
@@ -69,8 +69,8 @@ public UUID commitId() {
    * Valid-through timestamp, which is the min-of-max record timestamps across all workers for the
    * commit.
    */
-  public Long vtts() {
-    return vtts;
+  public Long validThroughTs() {
+    return validThroughTs;
   }
 
   @Override
@@ -86,7 +86,7 @@ public void put(int i, Object v) {
         this.commitId = (UUID) v;
         return;
       case 1:
-        this.vtts = (Long) v;
+        this.validThroughTs = (Long) v;
         return;
       default:
         // ignore the object, it must be from a newer version of the format
@@ -99,7 +99,7 @@ public Object get(int i) {
       case 0:
         return commitId;
       case 1:
-        return vtts;
+        return validThroughTs;
       default:
         throw new UnsupportedOperationException("Unknown field ordinal: " + i);
     }

diff --git a/...ka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitTablePayload.java b/...ka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitTablePayload.java
@@ -33,7 +33,7 @@ public class CommitTablePayload implements Payload {
   private UUID commitId;
   private TableName tableName;
   private Long snapshotId;
-  private Long vtts;
+  private Long validThroughTs;
   private final Schema avroSchema;
 
   private static final Schema AVRO_SCHEMA =
@@ -54,7 +54,7 @@ public class CommitTablePayload implements Payload {
           .nullable()
           .longType()
           .noDefault()
-          .name("vtts")
+          .name("validThroughTs")
           .prop(AvroSchemaUtil.FIELD_ID_PROP, 1403)
           .type()
           .nullable()
@@ -67,11 +67,12 @@ public CommitTablePayload(Schema avroSchema) {
     this.avroSchema = avroSchema;
   }
 
-  public CommitTablePayload(UUID commitId, TableName tableName, Long snapshotId, Long vtts) {
+  public CommitTablePayload(
+      UUID commitId, TableName tableName, Long snapshotId, Long validThroughTs) {
     this.commitId = commitId;
     this.tableName = tableName;
     this.snapshotId = snapshotId;
-    this.vtts = vtts;
+    this.validThroughTs = validThroughTs;
     this.avroSchema = AVRO_SCHEMA;
   }
 
@@ -87,8 +88,8 @@ public Long snapshotId() {
     return snapshotId;
   }
 
-  public Long vtts() {
-    return vtts;
+  public Long validThroughTs() {
+    return validThroughTs;
   }
 
   @Override
@@ -110,7 +111,7 @@ public void put(int i, Object v) {
         this.snapshotId = (Long) v;
         return;
       case 3:
-        this.vtts = (Long) v;
+        this.validThroughTs = (Long) v;
         return;
       default:
         // ignore the object, it must be from a newer version of the format
@@ -127,7 +128,7 @@ public Object get(int i) {
       case 2:
         return snapshotId;
       case 3:
-        return vtts;
+        return validThroughTs;
       default:
         throw new UnsupportedOperationException("Unknown field ordinal: " + i);
     }

diff --git a/...onnect-events/src/test/java/org/apache/iceberg/connect/events/EventSerializationTest.java b/...onnect-events/src/test/java/org/apache/iceberg/connect/events/EventSerializationTest.java
@@ -111,7 +111,7 @@ public void testCommitTableSerialization() {
     assertThat(payload.commitId()).isEqualTo(commitId);
     assertThat(payload.tableName().toIdentifier()).isEqualTo(TableIdentifier.parse("db.tbl"));
     assertThat(payload.snapshotId()).isEqualTo(1L);
-    assertThat(payload.vtts()).isEqualTo(2L);
+    assertThat(payload.validThroughTs()).isEqualTo(2L);
   }
 
   @Test
@@ -127,6 +127,6 @@ public void testCommitCompleteSerialization() {
     assertThat(result.type()).isEqualTo(event.type());
     CommitCompletePayload payload = (CommitCompletePayload) result.payload();
     assertThat(payload.commitId()).isEqualTo(commitId);
-    assertThat(payload.vtts()).isEqualTo(2L);
+    assertThat(payload.validThroughTs()).isEqualTo(2L);
   }
 }