Struct CsvSerializer 

pub struct CsvSerializer {
    builder: WriterBuilder,
    header: bool,
}

Define a struct for serializing CSV records to a stream

Fields

builder: WriterBuilder

header: bool

Implementations

impl CsvSerializer

pub fn new() -> CsvSerializer

Constructor for the CsvSerializer object

pub fn with_builder(self, builder: WriterBuilder) -> CsvSerializer

Method for setting the CSV writer builder

pub fn with_header(self, header: bool) -> CsvSerializer

Method for setting the CSV writer header status

Trait Implementations

impl BatchSerializer for CsvSerializer

fn serialize( &self, batch: RecordBatch, initial: bool, ) -> Result<Bytes, DataFusionError>

Asynchronously serializes a RecordBatch and returns the serialized bytes. Parameter initial signals whether the given batch is the first batch. This distinction is important for certain serializers (like CSV).

impl Debug for CsvSerializer

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

Formats the value using the given formatter.

impl Default for CsvSerializer

fn default() -> CsvSerializer

Returns the “default value” for a type.