From 2d8060c09d7bc6ceefc7fd41492821f179ae40a8 Mon Sep 17 00:00:00 2001 From: tanruixiang Date: Sun, 8 Oct 2023 17:45:13 +0800 Subject: [PATCH] format --- iox_query/src/exec/gapfill/algo.rs | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/iox_query/src/exec/gapfill/algo.rs b/iox_query/src/exec/gapfill/algo.rs index dd4aaf8..896b7e3 100644 --- a/iox_query/src/exec/gapfill/algo.rs +++ b/iox_query/src/exec/gapfill/algo.rs @@ -6,7 +6,7 @@ mod interpolate; use std::{ops::Range, sync::Arc}; use arrow::{ - array::{Array, ArrayRef, TimestampNanosecondArray, UInt64Array, PrimitiveArray}, + array::{Array, ArrayRef, PrimitiveArray, TimestampNanosecondArray, UInt64Array}, compute::kernels::take, datatypes::SchemaRef, record_batch::RecordBatch, @@ -153,7 +153,9 @@ impl GapFiller { .iter() .map(|(_, arr)| Arc::clone(arr)) .collect::>(); - let mut ranges = arrow::compute::partition(&sort_columns)?.ranges().into_iter(); + let mut ranges = arrow::compute::partition(&sort_columns)? + .ranges() + .into_iter(); let mut series_ends = vec![]; let mut cursor = self.cursor.clone_for_aggr_col(None)?; @@ -937,9 +939,9 @@ impl StashedAggrBuilder<'_> { /// `input_aggr_array` at `offset` for use with the [`interleave`](arrow::compute::interleave) /// kernel. fn create_stash(input_aggr_array: &ArrayRef, offset: u64) -> Result { - let take_arr:PrimitiveArray<_> = vec![None, Some(offset)].into(); + let take_arr: PrimitiveArray<_> = vec![None, Some(offset)].into(); let stash = - take::take(input_aggr_array, &take_arr, None).map_err(DataFusionError::ArrowError)?; + take::take(input_aggr_array, &take_arr, None).map_err(DataFusionError::ArrowError)?; Ok(stash) }