Struct ArrowRowGroupWriterFactory 

pub struct ArrowRowGroupWriterFactory {
    schema: SchemaDescPtr,
    arrow_schema: SchemaRef,
    props: WriterPropertiesPtr,
    file_encryptor: Option<Arc<FileEncryptor>>,
}

Factory that creates new column writers for each row group in the Parquet file.

Fields

schema: SchemaDescPtr

arrow_schema: SchemaRef

props: WriterPropertiesPtr

file_encryptor: Option<Arc<FileEncryptor>>

Implementations

impl ArrowRowGroupWriterFactory

pub fn new<W: Write + Send>( file_writer: &SerializedFileWriter<W>, arrow_schema: SchemaRef, ) -> Self

Create a new ArrowRowGroupWriterFactory for the provided file writer and Arrow schema

fn create_row_group_writer( &self, row_group_index: usize, ) -> Result<ArrowRowGroupWriter>

pub fn create_column_writers( &self, row_group_index: usize, ) -> Result<Vec<ArrowColumnWriter>>

Create column writers for a new row group.

fn column_writer_factory( &self, row_group_idx: usize, ) -> ArrowColumnWriterFactory