Skip to content

Commit 1319bfa

Browse files
committed
fix fmt
1 parent ddd0b57 commit 1319bfa

1 file changed

Lines changed: 14 additions & 10 deletions

File tree

datafusion/spark/src/function/string/concat_ws.rs

Lines changed: 14 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -231,19 +231,23 @@ fn collect_parts(arr: &ArrayRef, row_idx: usize, parts: &mut Vec<String>) -> Res
231231
parts.push(str_arr.value(row_idx).to_string());
232232
}
233233
DataType::Binary => {
234-
let bin_arr = arr.as_any().downcast_ref::<BinaryArray>().ok_or_else(
235-
|| datafusion_common::DataFusionError::Execution(
236-
"failed to downcast to BinaryArray".to_string(),
237-
),
238-
)?;
234+
let bin_arr =
235+
arr.as_any().downcast_ref::<BinaryArray>().ok_or_else(|| {
236+
datafusion_common::DataFusionError::Execution(
237+
"failed to downcast to BinaryArray".to_string(),
238+
)
239+
})?;
239240
parts.push(binary_to_utf8(bin_arr.value(row_idx))?);
240241
}
241242
DataType::LargeBinary => {
242-
let bin_arr = arr.as_any().downcast_ref::<LargeBinaryArray>().ok_or_else(
243-
|| datafusion_common::DataFusionError::Execution(
244-
"failed to downcast to LargeBinaryArray".to_string(),
245-
),
246-
)?;
243+
let bin_arr =
244+
arr.as_any()
245+
.downcast_ref::<LargeBinaryArray>()
246+
.ok_or_else(|| {
247+
datafusion_common::DataFusionError::Execution(
248+
"failed to downcast to LargeBinaryArray".to_string(),
249+
)
250+
})?;
247251
parts.push(binary_to_utf8(bin_arr.value(row_idx))?);
248252
}
249253
DataType::List(_) => {

0 commit comments

Comments
 (0)