File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
datafusion/datasource/src Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -217,7 +217,7 @@ impl DataSource for MemorySourceConfig {
217217 ) -> Result < Option < Arc < dyn DataSource > > > {
218218 // If there is any non-column or alias-carrier expression, Projection should not be removed.
219219 // This process can be moved into MemoryExec, but it would be an overlap of their responsibility.
220- let res = all_alias_free_columns ( projection)
220+ all_alias_free_columns ( projection)
221221 . then ( || {
222222 let all_projections = ( 0 ..self . schema . fields ( ) . len ( ) ) . collect ( ) ;
223223 let new_projections = new_projections_for_columns (
@@ -232,9 +232,7 @@ impl DataSource for MemorySourceConfig {
232232 )
233233 . map ( |s| Arc :: new ( s) as Arc < dyn DataSource > )
234234 } )
235- . transpose ( ) ?;
236-
237- Ok ( res)
235+ . transpose ( )
238236 }
239237}
240238
You can’t perform that action at this time.
0 commit comments