Struct AvroWriter

pub struct AvroWriter<W> { /* private fields */ }

Available on crate feature avro only.

Write a DataFrame to Apache Avro format

Example

use polars_core::prelude::*;
use polars_io::avro::AvroWriter;
use std::fs::File;
use polars_io::SerWriter;

fn example(df: &mut DataFrame) -> PolarsResult<()> {
    let mut file = File::create("file.avro").expect("could not create file");

    AvroWriter::new(&mut file)
        .finish(df)
}

Implementations

impl<W> AvroWriter<W>

where W: Write,

pub fn with_compression(self, compression: Option<AvroCompression>) -> Self

Set the compression used. Defaults to None.

pub fn with_name(self, name: String) -> Self

Trait Implementations

impl<W> SerWriter<W> for AvroWriter<W>

where W: Write,

fn new(writer: W) -> Self

fn finish(&mut self, df: &mut DataFrame) -> PolarsResult<()>