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 266daf8 commit 43ba6f2Copy full SHA for 43ba6f2
datafusion/physical-plan/src/sorts/sort.rs
@@ -935,11 +935,6 @@ impl SortExec {
935
}
936
937
938
- pub fn with_filter(mut self, filter: Arc<DynamicFilterPhysicalExpr>) -> Self {
939
- self.filter = Some(filter);
940
- self
941
- }
942
-
943
/// Input schema
944
pub fn input(&self) -> &Arc<dyn ExecutionPlan> {
945
&self.input
@@ -955,11 +950,6 @@ impl SortExec {
955
950
self.fetch
956
951
957
952
958
- /// If `Some(filter)`, returns the filter expression that matches the state of the sort.
959
- pub fn filter(&self) -> Option<Arc<DynamicFilterPhysicalExpr>> {
960
- self.filter.clone()
961
962
963
953
fn output_partitioning_helper(
964
954
input: &Arc<dyn ExecutionPlan>,
965
preserve_partitioning: bool,
0 commit comments