zz

```python table = catalog.load_table(("default", "mq_log10")) scan = table.scan() file_scan_tasks = scan.plan_files() partition_num = 20 new_file_scan_tasks = [] for task in file_scan_tasks: if task.file.partition[0] == partition_num: new_file_scan_tasks.append(task) # reference： # https://github.com/apache/iceberg-python/blob/pyiceberg-0.7.1/pyiceberg/table/__init__.py#L2014...

```python from pyiceberg.transforms import BucketTransform from pyiceberg.types import IntegerType id = 50 t = BucketTransform(50) bucket_int_func = t.transform(IntegerType()) bucket_num = bucket_int_func(id) print(bucket_num) ``` I looked into the source code again...

I also encountered this issue, thanks for your help!