(&self)
| 411 | } |
| 412 | |
| 413 | fn metrics(&self) -> Option<MetricsSet> { |
| 414 | let mut metrics = self.data_source.metrics().clone_inner(); |
| 415 | |
| 416 | // Add `output_rows_skew` metric to the metrics set. |
| 417 | // Done here because it's a derived metric from output_rows metric. |
| 418 | if let Some(file_scan_config) = self.data_source.downcast_ref::<FileScanConfig>() |
| 419 | && file_scan_config.file_source().file_type() == "parquet" |
| 420 | && let Some(output_rows_skew) = |
| 421 | BaselineMetrics::output_rows_skew_metric(&metrics) |
| 422 | { |
| 423 | metrics.push(output_rows_skew); |
| 424 | } |
| 425 | |
| 426 | Some(metrics) |
| 427 | } |
| 428 | |
| 429 | fn partition_statistics(&self, partition: Option<usize>) -> Result<Arc<Statistics>> { |
| 430 | self.data_source.partition_statistics(partition) |
no test coverage detected