Struct dataflow::decode::DataDecoder

struct DataDecoder {
    inner: DataDecoderInner,
    metrics: Metrics,
}

Fields

inner: DataDecoderInner

metrics: Metrics

Implementations

impl DataDecoder

pub fn next(&mut self, bytes: &mut &[u8]) -> Result<Option<Row>, DecodeError>

pub fn eof(&mut self, bytes: &mut &[u8]) -> Result<Option<Row>, DecodeError>

Get the next record if it exists, assuming an EOF has occurred.

This is distinct from next because, for example, a CSV record should be returned even if it does not end in a newline.

pub fn log_errors(&self, n: usize)

pub fn log_successes(&self, n: usize)

Trait Implementations

impl Debug for DataDecoder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.