We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8095609 commit dacfbaeCopy full SHA for dacfbae
datafusion/datasource/src/memory.rs
@@ -469,12 +469,15 @@ impl DataSource for MemorySourceConfig {
469
self.projection().as_ref().unwrap_or(&all_projections),
470
);
471
472
- MemorySourceConfig::try_new_exec(
+ MemorySourceConfig::try_new(
473
self.partitions(),
474
self.original_schema(),
475
Some(new_projections),
476
- )
477
- .map(|e| e as _)
+ ).and_then(|memory_source| {
+ // The projection gets applied to the sort information -- so we use the original underlying sort information.
478
+ let s = memory_source.try_with_sort_information(self.sort_information.clone())?;
479
+ Ok(Arc::new(DataSourceExec::new(Arc::new(s))) as _)
480
+ })
481
})
482
.transpose()
483
}
0 commit comments