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

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

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]

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

Formats the value using the given formatter. Read more

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]

pub fn type_id(&self) -> TypeId[src]

Gets the TypeId of self. Read more

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

pub fn borrow(&self) -> &T[src]

Immutably borrows from an owned value. Read more

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

pub fn borrow_mut(&mut self) -> &mut T[src]

Mutably borrows from an owned value. Read more

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

pub fn from(t: T) -> T[src]

Performs the conversion.

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

pub fn into(self) -> U[src]

Performs the conversion.

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.

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

Performs the conversion.

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.

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

Performs the conversion.

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

pub fn vzip(self) -> V