ray.data.datasource.FileBasedDatasource.apply_predicate

FileBasedDatasource.apply_predicate(predicate_expr: Expr) → Datasource

Apply a predicate to this datasource.

Default implementation that combines predicates using AND. Subclasses that support predicate pushdown should have a _predicate_expr attribute to store the predicate.

Note: Column rebinding is handled by the PredicatePushdown rule before this method is called, so the predicate_expr should already reference the correct column names.