Struct arrow::json::writer::Writer[][src]

pub struct Writer<W, F> where
    W: Write,
    F: JsonFormat
{ /* fields omitted */ }

A JSON writer which serializes RecordBatches to a stream of u8 encoded JSON objects. See the module level documentation for detailed usage and examples. The specific format of the stream is controlled by the JsonFormat type parameter.

Implementations

impl<W, F> Writer<W, F> where
    W: Write,
    F: JsonFormat
[src]

pub fn new(writer: W) -> Self[src]

Construct a new writer

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

Write a single JSON row to the output writer

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

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

pub fn finish(&mut self) -> Result<()>[src]

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[src]

Unwraps this Writer<W>, returning the underlying writer

Trait Implementations

impl<W: Debug, F: Debug> Debug for Writer<W, F> where
    W: Write,
    F: JsonFormat
[src]

Auto Trait Implementations

impl<W, F> RefUnwindSafe for Writer<W, F> where
    F: RefUnwindSafe,
    W: RefUnwindSafe

impl<W, F> Send for Writer<W, F> where
    F: Send,
    W: Send

impl<W, F> Sync for Writer<W, F> where
    F: Sync,
    W: Sync

impl<W, F> Unpin for Writer<W, F> where
    F: Unpin,
    W: Unpin

impl<W, F> UnwindSafe for Writer<W, F> where
    F: UnwindSafe,
    W: UnwindSafe

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,