Skip to content

Commit a000be7

Browse files
committed
Remove partition from statistics
1 parent ff92d0c commit a000be7

2 files changed

Lines changed: 3 additions & 9 deletions

File tree

datafusion-federation/src/sql/executor.rs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -47,12 +47,7 @@ pub trait SQLExecutor: Sync + Send {
4747
/// Returns statistics for this `SQLExecutor` node. If statistics are not available, it should
4848
/// return [`Statistics::new_unknown`] (the default), not an error. See the `ExecutionPlan`
4949
/// trait.
50-
fn partition_statistics(
51-
&self,
52-
_partition: Option<usize>,
53-
_query: &str,
54-
schema: SchemaRef,
55-
) -> Result<Statistics> {
50+
fn statistics(&self, _query: &str, schema: SchemaRef) -> Result<Statistics> {
5651
Ok(Statistics::new_unknown(&schema))
5752
}
5853

datafusion-federation/src/sql/mod.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -345,9 +345,8 @@ impl ExecutionPlan for VirtualExecutionPlan {
345345
&self.props
346346
}
347347

348-
fn partition_statistics(&self, partition: Option<usize>) -> Result<Statistics> {
349-
self.executor
350-
.partition_statistics(partition, &self.final_sql()?, self.schema())
348+
fn partition_statistics(&self, _partition: Option<usize>) -> Result<Statistics> {
349+
self.executor.statistics(&self.final_sql()?, self.schema())
351350
}
352351
}
353352

0 commit comments

Comments
 (0)