Struct ArrowPageWriter 

struct ArrowPageWriter {
    buffer: Arc<Mutex<ArrowColumnChunkData>>,
    page_encryptor: Option<PageEncryptor>,
}

Fields

buffer: Arc<Mutex<ArrowColumnChunkData>>

page_encryptor: Option<PageEncryptor>

Implementations

impl ArrowPageWriter

pub fn with_encryptor(self, page_encryptor: Option<PageEncryptor>) -> Self

fn page_encryptor_mut(&mut self) -> Option<&mut PageEncryptor>

Trait Implementations

impl Default for ArrowPageWriter

fn default() -> ArrowPageWriter

Returns the “default value” for a type.

impl PageWriter for ArrowPageWriter

fn write_page(&mut self, page: CompressedPage) -> Result<PageWriteSpec>

Writes a page into the output stream/sink. Returns PageWriteSpec that contains information about written page metrics, including number of bytes, size, number of values, offset, etc.

fn close(&mut self) -> Result<()>

Closes resources and flushes underlying sink. Page writer should not be used after this method is called.