Struct JsonNewLineStreamFormat 

pub struct JsonNewLineStreamFormat;

Available on crate feature json only.

JSON Lines: one JSON value per line, newline-terminated.

Implementations

impl JsonNewLineStreamFormat

pub fn new() -> Self

A JSON Lines format.

Trait Implementations

impl Clone for JsonNewLineStreamFormat

fn clone(&self) -> JsonNewLineStreamFormat

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for JsonNewLineStreamFormat

impl Debug for JsonNewLineStreamFormat

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

Formats the value using the given formatter.

impl Default for JsonNewLineStreamFormat

fn default() -> JsonNewLineStreamFormat

Returns the “default value” for a type.

impl DefaultFormat for JsonNewLineStreamFormat

fn default_format() -> Self

The configuration to use when the caller supplied none.

impl StreamFormat for JsonNewLineStreamFormat

fn format_name(&self) -> &'static str

A short, stable name, reported as the format tracing field.

fn default_content_type(&self) -> &'static str

The Content-Type this format emits when encoding.

fn accepts_content_type(&self, ct: &ContentType<'_>) -> bool

Whether an incoming Content-Type should be accepted as this format.

impl<T> StreamFormatDecode<T> for JsonNewLineStreamFormat

where T: for<'de> Deserialize<'de>,

type Frame = Result<T, StreamError>

One framed record, before deserialisation.

type Framer = JsonNewLineCodec<T>

Splits the body into records.

type Parser = IdentityParser

Deserialises framed records.

fn framer(&self, options: &DecodeOptions) -> Self::Framer

Build a framer for one body.

fn parser(&self) -> Self::Parser

Build a parser for one body.

impl<T> StreamFormatEncode<T> for JsonNewLineStreamFormat

where T: Serialize,

type Encoder = JsonNewLineEncoder

The per-stream encoder. A fresh one is built for every body, because framing state (item index, Arrow’s dictionary tracker, CSV’s header flag) is per-stream.

fn encoder(&self) -> Self::Encoder

Build an encoder for one body.