Struct NDJSONBatchBuilder 

pub struct NDJSONBatchBuilder { /* private fields */ }

NDJSON batch builder.

The builder accumulates serialized JSON values into an NDJSON batch of a given maximum size.

Implementations

impl NDJSONBatchBuilder

pub fn new(max_size: usize) -> Self

Create a new NDJSON batch builder with the given maximum batch size.

Trait Implementations

impl BatchBuilder for NDJSONBatchBuilder

type Item = Bytes

type Batch = Bytes

fn push(&mut self, item: Self::Item) -> Option<Self::Batch>

Push a given item into the builder.

fn flush(&mut self) -> Option<Self::Batch>

Flush the builder and return the accumulated batch, if any.