Struct RunEncodedEncoder 

struct RunEncodedEncoder<'a, R: RunEndIndexType> {
    ends_slice: &'a [<R as ArrowPrimitiveType>::Native],
    base: usize,
    len: usize,
    values: FieldEncoder<'a>,
    cur_run: usize,
    cur_end: usize,
}

Generic encoder for Arrow RunArray<R>-based sites (run-end encoded). Follows the pattern used by other generic encoders (i.e., ListEncoder<O>), avoiding runtime branching on run-end width.

Fields

ends_slice: &'a [<R as ArrowPrimitiveType>::Native]

base: usize

len: usize

values: FieldEncoder<'a>

cur_run: usize

cur_end: usize

Implementations

impl<'a, R: RunEndIndexType> RunEncodedEncoder<'a, R>

fn new(arr: &'a RunArray<R>, values: FieldEncoder<'a>) -> Self

fn advance_to_row(&mut self, idx: usize) -> Result<(), ArrowError>

Advance cur_run so that idx is within the run ending at cur_end. Uses the REE invariant: run ends are strictly increasing, positive, and 1-based.

fn encode<W: Write + ?Sized>( &mut self, out: &mut W, idx: usize, ) -> Result<(), ArrowError>