Skip to content

Commit

Permalink
Minor tweaks.
Browse files Browse the repository at this point in the history
  • Loading branch information
wypoon committed Sep 18, 2024
1 parent 7e061e7 commit c0df6d5
Showing 1 changed file with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ public void testRowDeletes() {

assertThat(tasks).as("Must have 4 tasks").hasSize(4);

DeletedRowsScanTask t1 = (DeletedRowsScanTask) Iterables.get(tasks, 0);
DeletedRowsScanTask t1 = (DeletedRowsScanTask) tasks.get(0);
assertThat(t1.changeOrdinal()).as("Ordinal must match").isEqualTo(0);
assertThat(t1.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap2.snapshotId());
assertThat(t1.file().path()).as("Data file must match").isEqualTo(FILE_B.path());
Expand All @@ -172,7 +172,7 @@ public void testRowDeletes() {
.isEqualTo(FILE_B_DELETES.path());
assertThat(t1.existingDeletes()).as("Must be no existing deletes").isEmpty();

DeletedRowsScanTask t2 = (DeletedRowsScanTask) Iterables.get(tasks, 1);
DeletedRowsScanTask t2 = (DeletedRowsScanTask) tasks.get(1);
assertThat(t2.changeOrdinal()).as("Ordinal must match").isEqualTo(1);
assertThat(t2.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap3.snapshotId());
assertThat(t2.file().path()).as("Data file must match").isEqualTo(FILE_C.path());
Expand All @@ -181,7 +181,7 @@ public void testRowDeletes() {
.isEqualTo(FILE_C2_DELETES.path());
assertThat(t2.existingDeletes()).as("Must be no existing deletes").isEmpty();

DeletedRowsScanTask t3 = (DeletedRowsScanTask) Iterables.get(tasks, 2);
DeletedRowsScanTask t3 = (DeletedRowsScanTask) tasks.get(2);
assertThat(t3.changeOrdinal()).as("Ordinal must match").isEqualTo(2);
assertThat(t3.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap4.snapshotId());
assertThat(t3.file().path()).as("Data file must match").isEqualTo(FILE_A2.path());
Expand All @@ -194,7 +194,7 @@ public void testRowDeletes() {
.isEqualTo(FILE_A_DELETES.path());
assertThat(t3.existingDeletes()).as("Must be no existing deletes").isEmpty();

DeletedRowsScanTask t4 = (DeletedRowsScanTask) Iterables.get(tasks, 3);
DeletedRowsScanTask t4 = (DeletedRowsScanTask) tasks.get(3);
assertThat(t4.changeOrdinal()).as("Ordinal must match").isEqualTo(2);
assertThat(t4.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap4.snapshotId());
assertThat(t4.file().path()).as("Data file must match").isEqualTo(FILE_A.path());
Expand Down Expand Up @@ -225,7 +225,7 @@ public void testAddingAndDeletingInSameCommit() {

assertThat(tasks).as("Must have 1 tasks").hasSize(1);

AddedRowsScanTask t1 = (AddedRowsScanTask) Iterables.get(tasks, 0);
AddedRowsScanTask t1 = (AddedRowsScanTask) tasks.get(0);
assertThat(t1.changeOrdinal()).as("Ordinal must match").isEqualTo(0);
assertThat(t1.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap2.snapshotId());
assertThat(t1.file().path()).as("Data file must match").isEqualTo(FILE_B.path());
Expand Down Expand Up @@ -254,7 +254,7 @@ public void testDeletingRowsInDataFileWithExistingDeletes() {

assertThat(tasks).as("Must have 1 task").hasSize(1);

DeletedRowsScanTask t1 = (DeletedRowsScanTask) Iterables.get(tasks, 0);
DeletedRowsScanTask t1 = (DeletedRowsScanTask) tasks.get(0);
assertThat(t1.changeOrdinal()).as("Ordinal must match").isEqualTo(0);
assertThat(t1.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap3.snapshotId());
assertThat(t1.file().path()).as("Data file must match").isEqualTo(FILE_A.path());
Expand Down Expand Up @@ -290,7 +290,7 @@ public void testDeletingDataFileWithExistingDeletes() {

assertThat(tasks).as("Must have 1 task").hasSize(1);

DeletedDataFileScanTask t1 = (DeletedDataFileScanTask) Iterables.get(tasks, 0);
DeletedDataFileScanTask t1 = (DeletedDataFileScanTask) tasks.get(0);
assertThat(t1.changeOrdinal()).as("Ordinal must match").isEqualTo(0);
assertThat(t1.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap3.snapshotId());
assertThat(t1.file().path()).as("Data file must match").isEqualTo(FILE_B.path());
Expand Down

0 comments on commit c0df6d5

Please sign in to comment.