geoffreyclaude opened a new pull request, #2521: URL: https://github.com/apache/iceberg-rust/pull/2521
## Which issue does this PR close? - Closes #2364. ## What changes are included in this PR? `IcebergTableScan` now owns a DataFusion `ExecutionPlanMetricsSet` and returns it from `ExecutionPlan::metrics()`. The scan output stream is wrapped in a small measured stream that records `BaselineMetrics` while the Iceberg stream is polled. This exposes the standard DataFusion operator metrics such as `elapsed_compute`, `output_rows`, `output_batches`, `output_bytes`, and completion timestamps in `EXPLAIN ANALYZE`. A focused unit test covers the measured stream wrapper and verifies that row and elapsed compute metrics are recorded. ## Are these changes tested? - `cargo test -p iceberg-datafusion measured_scan_stream_records_baseline_metrics --locked` - `cargo check -p iceberg-datafusion --locked` - `cargo test -p iceberg-datafusion --locked` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
