Type Alias arrow_json::writer::LineDelimitedWriter

pub type LineDelimitedWriter<W> = Writer<W, LineDelimited>;

A JSON writer which serializes RecordBatches to newline delimited JSON objects

Aliased Type

struct LineDelimitedWriter<W> { /* private fields */ }

Implementations

impl<W, F> Writer<W, F>where W: Write, F: JsonFormat,

pub fn new(writer: W) -> Self

Construct a new writer

pub fn write_row(&mut self, row: &Value) -> Result<(), ArrowError>

Write a single JSON row to the output writer

pub fn write(&mut self, batch: &RecordBatch) -> Result<(), ArrowError>

Convert the RecordBatch into JSON rows, and write them to the output

pub fn write_batches( &mut self, batches: &[&RecordBatch] ) -> Result<(), ArrowError>

Convert the RecordBatch into JSON rows, and write them to the output

pub fn finish(&mut self) -> Result<(), ArrowError>

Finishes the output stream. This function must be called after all record batches have been produced. (e.g. producing the final ']' if writing arrays.

pub fn into_inner(self) -> W

Unwraps this Writer<W>, returning the underlying writer

Trait Implementations

impl<W, F> Debug for Writer<W, F>where W: Write + Debug, F: JsonFormat + Debug,

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

Formats the value using the given formatter.

impl<W, F> RecordBatchWriter for Writer<W, F>where W: Write, F: JsonFormat,

fn write(&mut self, batch: &RecordBatch) -> Result<(), ArrowError>

Write a single batch to the writer.

fn close(self) -> Result<(), ArrowError>

Write footer or termination data, then mark the writer as done.