Skip to content

Commit

Permalink
clean up
Browse files Browse the repository at this point in the history
  • Loading branch information
jqin61 committed Mar 12, 2024
1 parent 3a2d3f3 commit dafb0a4
Showing 1 changed file with 0 additions and 32 deletions.
32 changes: 0 additions & 32 deletions pyiceberg/table/snapshots.py
Original file line number Diff line number Diff line change
Expand Up @@ -128,38 +128,6 @@ def __init__(self) -> None:
self.added_eq_deletes = 0
self.removed_eq_deletes = 0

# def added_file(file: DataFile) -> None:
# self.added_file_size += file.file_size_in_bytes
# if file.content == DataFileContent.DATA:
# self.added_data_files += 1
# self.added_records += file.record_count
# elif file.content == DataFileContent.POSITION_DELETES:
# self.added_delete_files += 1
# self.added_pos_delete_files += 1
# self.added_pos_deletes += file.record_count
# elif file.content == DataFileContent.EQUALITY_DELETES:
# self.added_delete_files += 1
# self.added_eq_delete_files += 1
# self.added_eq_deletes += file.record_count
# else:
# raise ValueError("Unsupported file content type: " + file.content())

# def removed_file(file: DataFile) -> None:
# self.removed_file_size += file.file_size_in_bytes
# if file.content == DataFileContent.DATA:
# self.removed_data_files += 1
# self.deleted_records += file.record_count
# elif file.content == DataFileContent.POSITION_DELETES:
# self.removed_delete_files += 1
# self.removed_pos_delete_files += 1
# self.removed_pos_deletes += file.record_count
# elif file.content == DataFileContent.EQUALITY_DELETES
# self.removed_delete_files += 1
# self.removed_eq_delete_files += 1
# self.removed_eq_deletes += file.record_count
# else:
# raise ValueError("Unsupported file content type: " + file.content())

def add_file(self, data_file: DataFile) -> None:
self.added_file_size += data_file.file_size_in_bytes

Expand Down

0 comments on commit dafb0a4

Please sign in to comment.