Skip to main content

decode_messages

fv_streams_engine::decode

Function decode_messages 

Source 
pub fn decode_messages(
    schema: &Arc<Schema>,
    messages: &[&[u8]],
    policy: OnBadData,
) -> Result<(RecordBatch, Vec<usize>, Vec<usize>), ArrowError>
Expand description

Decode messages under policy. Returns the batch, the indexes of the messages that became rows (in row order), and the indexes of the rescued messages (their rows follow, in order).