fix: nightly rustfmt import ordering

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: g-talbot

quickwit/quickwit-parquet-engine/src/merge/tests.rs

@@ -323,7 +323,9 @@ fn test_merge_per_output_metadata_from_actual_rows() {
         num_outputs: 1,
         writer_config: ParquetWriterConfig::default(),
     };
-    let outputs = merge_sorted_parquet_files(&[input1.clone(), input2.clone()], &output_dir, &config).unwrap();
+    let outputs =
+        merge_sorted_parquet_files(&[input1.clone(), input2.clone()], &output_dir, &config)
+            .unwrap();
     assert_eq!(outputs.len(), 1);
     let output = &outputs[0];
     assert!(output.metric_names.contains("cpu"));

quickwit/quickwit-parquet-engine/src/merge/writer.rs

@@ -40,7 +40,9 @@ use crate::row_keys;
 use crate::sort_fields::parse_sort_fields;
 use crate::sorted_series::SORTED_SERIES_COLUMN;
 use crate::split::TAG_SERVICE;
-use crate::storage::split_writer::{extract_metric_names, extract_service_names, extract_time_range};
+use crate::storage::split_writer::{
+    extract_metric_names, extract_service_names, extract_time_range,
+};
 use crate::storage::{
     PARQUET_META_NUM_MERGE_OPS, PARQUET_META_ROW_KEYS, PARQUET_META_ROW_KEYS_JSON,
     PARQUET_META_SORT_FIELDS, PARQUET_META_WINDOW_DURATION, PARQUET_META_WINDOW_START,
@@ -119,8 +121,8 @@ pub fn write_merge_outputs(
         // Extract per-output logical metadata from the actual rows.
         let metric_names = extract_metric_names(&sorted_batch)
             .context("extracting metric names from merge output")?;
-        let time_range = extract_time_range(&sorted_batch)
-            .context("extracting time range from merge output")?;
+        let time_range =
+            extract_time_range(&sorted_batch).context("extracting time range from merge output")?;
         let service_names = extract_service_names(&sorted_batch)
             .context("extracting service names from merge output")?;
 

quickwit/quickwit-parquet-engine/src/storage/split_writer.rs

@@ -194,7 +194,9 @@ pub(crate) fn extract_time_range(batch: &RecordBatch) -> Result<TimeRange, Parqu
 }
 
 /// Extracts distinct metric names from a RecordBatch.
-pub(crate) fn extract_metric_names(batch: &RecordBatch) -> Result<HashSet<String>, ParquetWriteError> {
+pub(crate) fn extract_metric_names(
+    batch: &RecordBatch,
+) -> Result<HashSet<String>, ParquetWriteError> {
     let metric_idx = batch
         .schema()
         .index_of("metric_name")
@@ -227,7 +229,9 @@ pub(crate) fn extract_metric_names(batch: &RecordBatch) -> Result<HashSet<String
 }
 
 /// Extracts distinct service names from a RecordBatch.
-pub(crate) fn extract_service_names(batch: &RecordBatch) -> Result<HashSet<String>, ParquetWriteError> {
+pub(crate) fn extract_service_names(
+    batch: &RecordBatch,
+) -> Result<HashSet<String>, ParquetWriteError> {
     let service_idx = match batch.schema().index_of("service").ok() {
         Some(idx) => idx,
         None => return Ok(HashSet::new()),