File tree 1 file changed +11
-5
lines changed 1 file changed +11
-5
lines changed Original file line number Diff line number Diff line change @@ -117,10 +117,16 @@ impl TableProvider for Dataset {
117
117
118
118
/// Tests whether the table provider can make use of a filter expression
119
119
/// to optimise data retrieval.
120
- fn supports_filter_pushdown ( & self , filter : & Expr ) -> DFResult < TableProviderFilterPushDown > {
121
- match PyArrowFilterExpression :: try_from ( filter) {
122
- Ok ( _) => Ok ( TableProviderFilterPushDown :: Exact ) ,
123
- _ => Ok ( TableProviderFilterPushDown :: Unsupported ) ,
124
- }
120
+ fn supports_filters_pushdown (
121
+ & self ,
122
+ filter : & [ & Expr ] ,
123
+ ) -> DFResult < Vec < TableProviderFilterPushDown > > {
124
+ filter
125
+ . iter ( )
126
+ . map ( |& f| match PyArrowFilterExpression :: try_from ( f) {
127
+ Ok ( _) => Ok ( TableProviderFilterPushDown :: Exact ) ,
128
+ _ => Ok ( TableProviderFilterPushDown :: Unsupported ) ,
129
+ } )
130
+ . collect ( )
125
131
}
126
132
}
You can’t perform that action at this time.
0 commit comments