We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b12945c commit 99ed041Copy full SHA for 99ed041
datafusion/datasource-parquet/src/source.rs
@@ -781,3 +781,19 @@ impl FileSource for ParquetSource {
781
self.schema_adapter_factory.clone()
782
}
783
784
+
785
+#[cfg(test)]
786
+mod tests {
787
+ use super::*;
788
+ use datafusion_physical_expr::expressions::lit;
789
790
+ #[test]
791
+ #[allow(deprecated)]
792
+ fn test_parquet_source_predicate_same_as_filter() {
793
+ let predicate = lit(true);
794
795
+ let parquet_source = ParquetSource::default().with_predicate(predicate);
796
+ // same value. but filter() call Arc::clone internally
797
+ assert_eq!(parquet_source.predicate(), parquet_source.filter().as_ref());
798
+ }
799
+}
0 commit comments