pub fn finish(&mut self) -> Result<()> {
        // write EOS
        write_continuation(&mut self.writer, 0)?;

        let schema = schema::serialize_schema(&self.schema, &self.ipc_fields);

        let root = arrow_format::ipc::Footer {
            version: arrow_format::ipc::MetadataVersion::V5,
            schema: Some(Box::new(schema)),
            dictionaries: Some(std::mem::take(&mut self.dictionary_blocks)),
            record_batches: Some(std::mem::take(&mut self.record_blocks)),
            custom_metadata: None,
        };
        let mut builder = Builder::new();
        let footer_data = builder.finish(&root, None);
        self.writer.write_all(footer_data)?;
        self.writer
            .write_all(&(footer_data.len() as i32).to_le_bytes())?;
        self.writer.write_all(&ARROW_MAGIC)?;
        self.writer.flush()?;
        self.finished = true;

        Ok(())
    }
/// Write footer and closing tag, then mark the writer as done
Write footer and closing tag, then mark the writer as done
Write footer and closing tag then mark the writer as done
pub fn finish(&mut self) -> Result<()> {
        // write EOS
        write_continuation(&mut self.writer, 0)?;
        let schema = schema::serialize_schema(&self.schema, &self.ipc_fields);
        let root = arrow_format::ipc::Footer {
            version: arrow_format::ipc::MetadataVersion::V5,
            schema: Some(Box::new(schema)),
            dictionaries: Some(std::mem::take(&mut self.dictionary_blocks)),
            record_batches: Some(std::mem::take(&mut self.record_blocks)),
            custom_metadata: None,
        };
        let mut builder = Builder::new();
        let footer_data = builder.finish(&root, None);
        self.writer.write_all(footer_data)?;
        self.writer
            .write_all(&(footer_data.len() as i32).to_le_bytes())?;
        self.writer.write_all(&ARROW_MAGIC)?;
        self.writer.flush()?;
        self.finished = true;
        Ok(())
    }
pub fn finish ( & mut self ) -> Result < ( ) > { // write EOS write_continuation ( & mut self . writer , 0 ) ? ; let schema = schema :: serialize_schema ( & self . schema , & self . ipc_fields ) ; let root = arrow_format :: ipc :: Footer { version : arrow_format :: ipc :: MetadataVersion :: V5 , schema : Some ( Box :: new ( schema ) ) , dictionaries : Some ( std :: mem :: take ( & mut self . dictionary_blocks ) ) , record_batches : Some ( std :: mem :: take ( & mut self . record_blocks ) ) , custom_metadata : None , } ; let mut builder = Builder :: new ( ) ; let footer_data = builder . finish ( & root , None ) ; self . writer . write_all ( footer_data ) ? ; self . writer . write_all ( & ( footer_data . len ( ) as i32 ) . to_le_bytes ( ) ) ? ; self . writer . write_all ( & ARROW_MAGIC ) ? ; self . writer . flush ( ) ? ; self . finished = true ; Ok ( ( ) ) }
Write footer and closing tag, then mark the writer as done
Write footer and closing tag then mark the writer as done
&mut self
&mut self