Function decode_fixed_size_binary

arrow-row/src/fixed.rs:481–515

Decodes a `FixedLengthBinary` from rows # Panics: Panics if `size` is negative

(
    rows: &mut [&[u8]],
    size: i32,
    options: SortOptions,
)

/// # Panics:
/// Panics if `size` is negative
pub fn decode_fixed_size_binary(
    rows: &mut [&[u8]],
    size: i32,
    options: SortOptions,
) -> FixedSizeBinaryArray {
    let len = rows.len();

    if size < 0 {
        panic!("cannot decode FixedSizeBinary({size})");
    }
    let mut values = MutableBuffer::new(size as usize * rows.len());
    let (null_count, nulls) = decode_nulls(rows);

    let encoded_len = size as usize + 1;

    for row in rows {
        let i = split_off(row, encoded_len);
        values.extend_from_slice(&i[1..]);
    }

    if options.descending {
        for v in values.as_slice_mut() {
            *v = !*v;
        }
    }

    let builder = ArrayDataBuilder::new(DataType::FixedSizeBinary(size))
        .len(len)
        .null_count(null_count)
        .add_buffer(values.into())
        .null_bit_buffer(Some(nulls));

    // SAFETY: Buffers correct length
    unsafe { builder.build_unchecked().into() }
}