Skip to content

Commit 47adf22

Browse files
committed
update
1 parent e2656c9 commit 47adf22

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

arrow-row/src/variable.rs

+6-6
Original file line numberDiff line numberDiff line change
@@ -263,16 +263,16 @@ fn decode_binary_view_inner(
263263
let mut output_buffer_cap = 0;
264264
let mut inline_buffer_cap = 0;
265265
for r in rows.iter() {
266-
let len = decoded_len(r, options);
267-
if len > 12 {
268-
output_buffer_cap += len;
266+
let l = decoded_len(r, options);
267+
if l <= 12 {
268+
inline_buffer_cap += l;
269269
} else {
270-
inline_buffer_cap += len;
270+
output_buffer_cap += l;
271271
}
272272
}
273273

274-
let mut output_buffer = MutableBuffer::new(output_buffer_cap);
275274
let mut inline_buffer = MutableBuffer::new(inline_buffer_cap);
275+
let mut output_buffer = MutableBuffer::new(output_buffer_cap);
276276
let mut views = BufferBuilder::<u128>::new(len);
277277

278278
for row in rows {
@@ -307,8 +307,8 @@ fn decode_binary_view_inner(
307307
if check_utf8 {
308308
// We validate the utf8 of the output buffer and the inline buffer
309309
// This is much faster than validating each string individually
310-
std::str::from_utf8(output_buffer.as_slice()).unwrap();
311310
std::str::from_utf8(inline_buffer.as_slice()).unwrap();
311+
std::str::from_utf8(output_buffer.as_slice()).unwrap();
312312
}
313313

314314
let builder = ArrayDataBuilder::new(DataType::BinaryView)

0 commit comments

Comments
 (0)