MCPcopy Create free account
hub / github.com/apache/paimon-rust / batch_to_serialized_bytes

Function batch_to_serialized_bytes

crates/paimon/src/spec/binary_row.rs:1130–1137  ·  view source on GitHub ↗

Batch-compute serialized partition bytes for all rows. Returns one `Vec ` per row, identical to calling `BinaryRow::from_arrow(batch, row_idx, field_indices, fields).to_serialized_bytes()` for each row, but with O(F) column downcasts instead of O(N*F).

(
    batch: &RecordBatch,
    field_indices: &[usize],
    fields: &[crate::spec::DataField],
)

Source from the content-addressed store, hash-verified

1128/// `BinaryRow::from_arrow(batch, row_idx, field_indices, fields).to_serialized_bytes()`
1129/// for each row, but with O(F) column downcasts instead of O(N*F).
1130pub fn batch_to_serialized_bytes(
1131 batch: &RecordBatch,
1132 field_indices: &[usize],
1133 fields: &[crate::spec::DataField],
1134) -> crate::Result<Vec<Vec<u8>>> {
1135 let rows = batch_build_binary_rows(batch, field_indices, fields)?;
1136 Ok(rows.into_iter().map(|r| r.to_serialized_bytes()).collect())
1137}
1138
1139/// Batch-compute Murmur3 hash codes for all rows.
1140/// Returns one `i32` per row, identical to calling

Callers 6

assign_batchMethod · 0.85
load_from_data_scanMethod · 0.85
assign_batchMethod · 0.85
assign_batchMethod · 0.85
assign_batchMethod · 0.85

Calls 2

batch_build_binary_rowsFunction · 0.85
to_serialized_bytesMethod · 0.80

Tested by

no test coverage detected