Skip to main content

RowDecoder

fluss::row

Trait RowDecoder 

Source 
pub trait RowDecoder: Send + Sync {
    // Required method
    fn decode<'a>(&self, data: &'a [u8]) -> CompactedRow<'a>;
}
Expand description

Decoder for creating BinaryRow from bytes.

This trait provides an abstraction for decoding different row formats (COMPACTED, INDEXED, etc.) from binary data.

Reference: org.apache.fluss.row.decode.RowDecoder

Required Methods§

Source

fn decode<'a>(&self, data: &'a [u8]) -> CompactedRow<'a>

Decode bytes into a CompactedRow.

The lifetime ’a ties the returned row to the input data, ensuring the data remains valid as long as the row is used.

Implementors§