File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1841,13 +1841,11 @@ def _build_metrics_evaluator(self) -> Callable[[DataFile], bool]:
18411841 def _build_residual_evaluator (self , spec_id : int ) -> Callable [[DataFile ], ResidualEvaluator ]:
18421842 spec = self .table_metadata .specs ()[spec_id ]
18431843
1844+ from pyiceberg .expressions .visitors import residual_evaluator_of
1845+
18441846 # The lambda created here is run in multiple threads.
18451847 # So we avoid creating _EvaluatorExpression methods bound to a single
18461848 # shared instance across multiple threads.
1847- # return lambda data_file: (partition_schema, partition_expr, self.case_sensitive)(data_file.partition)
1848- from pyiceberg .expressions .visitors import residual_evaluator_of
1849-
1850- # assert self.row_filter == False
18511849 return lambda datafile : (
18521850 residual_evaluator_of (
18531851 spec = spec ,
You can’t perform that action at this time.
0 commit comments