Skip to content

Commit e7e62f9

Browse files
committed
add back with_predicate for VortexSource
1 parent 58b39b4 commit e7e62f9

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

vortex-datafusion/src/persistent/source.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,13 @@ impl VortexSource {
7272
}
7373
}
7474

75+
/// Sets a [`VortexExpr`] as a predicate
76+
pub fn with_predicate(&self, predicate: PhysicalExprRef) -> Self {
77+
let mut source = self.clone();
78+
source.predicate = Some(predicate);
79+
source
80+
}
81+
7582
/// Sets a [`PhysicalExprAdapterFactory`] for the [`VortexSource`].
7683
/// Currently, this must be provided in order to filter columns in files that have a different data type from the unified table schema.
7784
///

0 commit comments

Comments
 (0)