Skip to content

Commit fc66c4a

Browse files
committed
removed un-needed ut8 check
1 parent 5d6a9b0 commit fc66c4a

1 file changed

Lines changed: 6 additions & 9 deletions

File tree

  • datafusion/physical-plan/src/aggregates/group_values/single_group_by

datafusion/physical-plan/src/aggregates/group_values/single_group_by/dictionary.rs

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -49,12 +49,11 @@ macro_rules! decode_list {
4949
if len == -1 {
5050
builder.values().append_null();
5151
} else {
52-
let s = std::str::from_utf8(
53-
&raw_vector[offset..offset + len as usize],
54-
)
55-
.map_err(|e| {
56-
Internal(format!("Invalid utf8 in list element: {e}"))
57-
})?;
52+
let s = unsafe {
53+
std::str::from_utf8_unchecked(
54+
&raw_vector[offset..offset + len as usize],
55+
)
56+
};
5857
builder.values().append_value(s);
5958
offset += len as usize;
6059
}
@@ -72,9 +71,7 @@ macro_rules! decode_scalar_string {
7271
for raw_bytes in $raw {
7372
match raw_bytes {
7473
Some(raw_vector) => {
75-
let s = std::str::from_utf8(raw_vector).map_err(|e| {
76-
Internal(format!("Invalid utf8 in GroupValuesDictionary: {e}"))
77-
})?;
74+
let s = unsafe { std::str::from_utf8_unchecked(raw_vector) };
7875
builder.append_value(s);
7976
}
8077
None => builder.append_null(),

0 commit comments

Comments
 (0)