From dafb0a441c1636023c3e931d2ab699123a2adc36 Mon Sep 17 00:00:00 2001 From: Adrian Qin <147659252+jqin61@users.noreply.github.com> Date: Tue, 12 Mar 2024 17:58:33 +0000 Subject: [PATCH] clean up --- pyiceberg/table/snapshots.py | 32 -------------------------------- 1 file changed, 32 deletions(-) diff --git a/pyiceberg/table/snapshots.py b/pyiceberg/table/snapshots.py index 48f3041b02..769bb7bf8a 100644 --- a/pyiceberg/table/snapshots.py +++ b/pyiceberg/table/snapshots.py @@ -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