Function encode_records 

pub fn encode_records(
    records: &[Arc<DataRecord>],
    schema: &Arc<Schema>,
) -> Result<RecordBatch, WpArrowError>

多条 DataRecord → 一个 RecordBatch。

每个列按名字在每条记录里查找；缺字段 → null。records 为空时按 schema 产零行（列类型齐全，便于下游直接 append）。