From eea96b34988aafd25b12dd9bce6eb429671b114e Mon Sep 17 00:00:00 2001 From: Xuanwo Date: Mon, 22 Jul 2024 01:12:40 +0800 Subject: [PATCH] Format code Signed-off-by: Xuanwo --- native/core/benches/cast_from_string.rs | 2 +- native/core/benches/cast_numeric.rs | 2 +- native/core/benches/shuffle_writer.rs | 2 +- native/core/src/execution/datafusion/spark_hash.rs | 4 +++- 4 files changed, 6 insertions(+), 4 deletions(-) diff --git a/native/core/benches/cast_from_string.rs b/native/core/benches/cast_from_string.rs index eef4e5eff..51410a68a 100644 --- a/native/core/benches/cast_from_string.rs +++ b/native/core/benches/cast_from_string.rs @@ -75,7 +75,7 @@ fn create_utf8_batch() -> RecordBatch { } } let array = b.finish(); - + RecordBatch::try_new(schema.clone(), vec![Arc::new(array)]).unwrap() } diff --git a/native/core/benches/cast_numeric.rs b/native/core/benches/cast_numeric.rs index f3941c16f..dc0ceea79 100644 --- a/native/core/benches/cast_numeric.rs +++ b/native/core/benches/cast_numeric.rs @@ -63,7 +63,7 @@ fn create_int32_batch() -> RecordBatch { } } let array = b.finish(); - + RecordBatch::try_new(schema.clone(), vec![Arc::new(array)]).unwrap() } diff --git a/native/core/benches/shuffle_writer.rs b/native/core/benches/shuffle_writer.rs index 1d28e26e6..6f2871861 100644 --- a/native/core/benches/shuffle_writer.rs +++ b/native/core/benches/shuffle_writer.rs @@ -65,7 +65,7 @@ fn create_batch() -> RecordBatch { } } let array = b.finish(); - + RecordBatch::try_new(schema.clone(), vec![Arc::new(array)]).unwrap() } diff --git a/native/core/src/execution/datafusion/spark_hash.rs b/native/core/src/execution/datafusion/spark_hash.rs index 201ecbbb0..e429f5439 100644 --- a/native/core/src/execution/datafusion/spark_hash.rs +++ b/native/core/src/execution/datafusion/spark_hash.rs @@ -686,7 +686,9 @@ mod tests { #[test] fn test_str() { - let input = ["hello", "bar", "", "😁", "天地", "a", "ab", "abc", "abcd", "abcde"] + let input = [ + "hello", "bar", "", "😁", "天地", "a", "ab", "abc", "abcd", "abcde", + ] .iter() .map(|s| Some(s.to_string())) .collect::>>();