Struct AuthorProcessor

pub struct AuthorProcessor {
    rec_writer: TableWriter<AuthorRec>,
    name_writer: TableWriter<AuthorNameRec>,
}

Process author records into Parquet.

Fields

rec_writer: TableWriter<AuthorRec>

name_writer: TableWriter<AuthorNameRec>

Implementations

impl AuthorProcessor

pub fn new() -> Result<AuthorProcessor>

Trait Implementations

impl ObjectWriter<Row<OLAuthorSource>> for AuthorProcessor

fn write_object(&mut self, row: Row<OLAuthorSource>) -> Result<()>

Write one object.

fn finish(self) -> Result<usize>

Finish and close the target.

fn write_all_objects<I>(&mut self, objects: I) -> Result<usize>

where I: Iterator<Item = T>,

Write an iterator full of objects.

fn write_and_finish<I>(self, objects: I) -> Result<usize>

where I: Iterator<Item = T>,

Write an iterator of objects and finish the writer.

fn with_transform<F, T2>(self, transform: F) -> MapWriter<F, T2, T, Self>

where F: Fn(T2) -> Result<T>,

Wrap this object writer in a transformed writer.