结构体 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,
}

用于 Arrow RunArray<R>-based 站点（行程编码）的通用编码器。遵循其他通用编码器（例如 ListEncoder<O>）使用的模式，避免了行程结束宽度上的运行时分支。

字段

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

base: usize

len: usize

values: FieldEncoder<'a>

cur_run: usize

cur_end: usize

实现

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>

推进 cur_run，使 idx 位于以 cur_end 结束的运行中。使用 REE 不变式：运行结束严格递增、为正且从 1 开始。

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