File tree Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -183,11 +183,10 @@ pub struct FileScanConfig {
183
183
/// Expression adapter used to adapt filters and projections that are pushed down into the scan
184
184
/// from the logical schema to the physical schema of the file.
185
185
pub expr_adapter_factory : Option < Arc < dyn PhysicalExprAdapterFactory > > ,
186
-
186
+ /// Optional metrics
187
187
pub metrics : ExecutionPlanMetricsSet ,
188
+ /// Optional user defined schema adapter
188
189
pub schema_adapter_factory : Option < Arc < dyn SchemaAdapterFactory > > ,
189
-
190
- ///
191
190
pub projected_statistics : Statistics ,
192
191
}
193
192
Original file line number Diff line number Diff line change @@ -760,7 +760,7 @@ impl protobuf::PhysicalPlanNode {
760
760
) ?;
761
761
762
762
let source = AvroSource :: new ( conf) ;
763
- Ok ( DataSourceExec :: from_data_source ( conf ) )
763
+ Ok ( DataSourceExec :: from_data_source ( source ) )
764
764
}
765
765
#[ cfg( not( feature = "avro" ) ) ]
766
766
panic ! ( "Unable to process a Avro PhysicalPlan when `avro` feature is not enabled" )
You can’t perform that action at this time.
0 commit comments