pub struct Writer<W, F> where
W: Write,
F: JsonFormat, { /* private fields */ }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
sourceimpl<W, F> Writer<W, F> where
W: Write,
F: JsonFormat,
impl<W, F> Writer<W, F> where
W: Write,
F: JsonFormat,
sourcepub fn write_row(&mut self, row: &Value) -> Result<()>
pub fn write_row(&mut self, row: &Value) -> Result<()>
Write a single JSON row to the output writer
sourcepub fn write(&mut self, batch: RecordBatch) -> Result<()>
pub fn write(&mut self, batch: RecordBatch) -> Result<()>
Convert the RecordBatch into JSON rows, and write them to the output
sourcepub fn write_batches(&mut self, batches: &[RecordBatch]) -> Result<()>
pub fn write_batches(&mut self, batches: &[RecordBatch]) -> Result<()>
Convert the RecordBatch into JSON rows, and write them to the output
sourcepub fn finish(&mut self) -> Result<()>
pub fn finish(&mut self) -> Result<()>
Finishes the output stream. This function must be called after
all record batches have been produced. (e.g. producing the final ']' if writing
arrays.
sourcepub fn into_inner(self) -> W
pub fn into_inner(self) -> W
Unwraps this Writer<W>, returning the underlying writer
Trait Implementations
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
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more