arrow2 0.10.1

Unofficial implementation of Apache Arrow spec in safe Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use futures::{AsyncWrite, AsyncWriteExt};

use crate::error::Result;

use super::super::write::{util::zigzag_encode, SYNC_NUMBER};
use super::super::CompressedBlock;

/// Writes a [`CompressedBlock`] to `writer`
pub async fn write_block<W>(writer: &mut W, compressed_block: &CompressedBlock) -> Result<()>
where
    W: AsyncWrite + Unpin,
{
    // write size and rows
    let mut scratch = Vec::with_capacity(10);
    zigzag_encode(compressed_block.number_of_rows as i64, &mut scratch)?;
    writer.write_all(&scratch).await?;
    scratch.clear();
    zigzag_encode(compressed_block.data.len() as i64, &mut scratch)?;
    writer.write_all(&scratch).await?;

    writer.write_all(&compressed_block.data).await?;

    writer.write_all(&SYNC_NUMBER).await?;

    Ok(())
}