Skip to content

Commit ab7044e

Browse files
committed
Minor tweaks.
1 parent 98902eb commit ab7044e

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

Diff for: core/src/test/java/org/apache/iceberg/TestBaseIncrementalChangelogScan.java

+7-7
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ public void testRowDeletes() {
163163

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

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

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

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

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

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

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

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

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

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

293-
DeletedDataFileScanTask t1 = (DeletedDataFileScanTask) Iterables.get(tasks, 0);
293+
DeletedDataFileScanTask t1 = (DeletedDataFileScanTask) tasks.get(0);
294294
assertThat(t1.changeOrdinal()).as("Ordinal must match").isEqualTo(0);
295295
assertThat(t1.commitSnapshotId()).as("Snapshot must match").isEqualTo(snap3.snapshotId());
296296
assertThat(t1.file().path()).as("Data file must match").isEqualTo(FILE_B.path());

0 commit comments

Comments
 (0)