Skip to content

Commit 9913dea

Browse files
committed
remove unnecessary .previousFiles(..) calls
1 parent ecbe310 commit 9913dea

File tree

2 files changed

+0
-16
lines changed

2 files changed

+0
-16
lines changed

core/src/main/java/org/apache/iceberg/TableMetadata.java

-15
Original file line numberDiff line numberDiff line change
@@ -410,7 +410,6 @@ public TableMetadata withUUID() {
410410
return ImmutableTableMetadata.builder()
411411
.from(this)
412412
.uuid(UUID.randomUUID().toString())
413-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
414413
.build();
415414
}
416415
}
@@ -441,7 +440,6 @@ public TableMetadata updateSchema(Schema newSchema, int newLastColumnId) {
441440
.schemas(builder.build())
442441
.specs(updatedSpecs)
443442
.sortOrders(updatedSortOrders)
444-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
445443
.build();
446444
}
447445

@@ -482,7 +480,6 @@ public TableMetadata updatePartitionSpec(PartitionSpec newPartitionSpec) {
482480
.defaultSpecId(newDefaultSpecId)
483481
.specs(builder.build())
484482
.lastAssignedPartitionId(Math.max(lastAssignedPartitionId(), newPartitionSpec.lastAssignedFieldId()))
485-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
486483
.build();
487484
}
488485

@@ -523,7 +520,6 @@ public TableMetadata replaceSortOrder(SortOrder newOrder) {
523520
.lastUpdatedMillis(System.currentTimeMillis())
524521
.defaultSortOrderId(newOrderId)
525522
.sortOrders(builder.build())
526-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
527523
.build();
528524
}
529525

@@ -542,7 +538,6 @@ public TableMetadata addStagedSnapshot(Snapshot snapshot) {
542538
.lastSequenceNumber(snapshot.sequenceNumber())
543539
.lastUpdatedMillis(snapshot.timestampMillis())
544540
.snapshots(newSnapshots)
545-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
546541
.build();
547542
}
548543

@@ -573,7 +568,6 @@ public TableMetadata replaceCurrentSnapshot(Snapshot snapshot) {
573568
.currentSnapshotId(snapshot.snapshotId())
574569
.snapshots(newSnapshots)
575570
.snapshotLog(newSnapshotLog)
576-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
577571
.build();
578572
}
579573

@@ -608,7 +602,6 @@ public TableMetadata removeSnapshotsIf(Predicate<Snapshot> removeIf) {
608602
.lastUpdatedMillis(System.currentTimeMillis())
609603
.snapshots(filtered)
610604
.snapshotLog(newSnapshotLog)
611-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
612605
.build();
613606
}
614607

@@ -634,7 +627,6 @@ private TableMetadata setCurrentSnapshotTo(Snapshot snapshot) {
634627
.lastUpdatedMillis(nowMillis)
635628
.currentSnapshotId(snapshot.snapshotId())
636629
.snapshotLog(newSnapshotLog)
637-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
638630
.build();
639631
}
640632

@@ -673,7 +665,6 @@ public TableMetadata removeSnapshotLogEntries(Set<Long> snapshotIds) {
673665
.from(this)
674666
.lastUpdatedMillis(System.currentTimeMillis())
675667
.snapshotLog(newSnapshotLog)
676-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
677668
.build();
678669
}
679670

@@ -829,7 +820,6 @@ public TableMetadata updateLocation(String newLocation) {
829820
.from(this)
830821
.location(newLocation)
831822
.lastUpdatedMillis(System.currentTimeMillis())
832-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
833823
.build();
834824
}
835825

@@ -847,14 +837,9 @@ public TableMetadata upgradeToFormatVersion(int newFormatVersion) {
847837
.from(this)
848838
.formatVersion(newFormatVersion)
849839
.lastUpdatedMillis(System.currentTimeMillis())
850-
.previousFiles(addPreviousFile(metadataFileLocation(), lastUpdatedMillis()))
851840
.build();
852841
}
853842

854-
private List<MetadataLogEntry> addPreviousFile(String previousFile, long timestampMillis) {
855-
return addPreviousFile(previousFile, timestampMillis, properties());
856-
}
857-
858843
private List<MetadataLogEntry> addPreviousFile(String previousFile, long timestampMillis,
859844
Map<String, String> updatedProperties) {
860845
if (previousFile == null) {

core/src/test/java/org/apache/iceberg/TestTableMetadata.java

-1
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,6 @@ public void testJsonConversion() throws Exception {
122122
.currentSnapshotId(currentSnapshotId)
123123
.snapshots(Arrays.asList(previousSnapshot, currentSnapshot))
124124
.snapshotLog(snapshotLog)
125-
.previousFiles(ImmutableList.of())
126125
.build();
127126

128127
String asJson = TableMetadataParser.toJson(expected);

0 commit comments

Comments
 (0)