Struct Part

pub struct Part {
    pub key: Arc<dyn Array>,
    pub val: Arc<dyn Array>,
    pub time: Int64Array,
    pub diff: Int64Array,
}

A structured columnar representation of one blob’s worth of data.

Fields

key: Arc<dyn Array>

The ‘k’ values from a Part, generally SourceData.

val: Arc<dyn Array>

The ‘v’ values from a Part, generally ().

time: Int64Array

The ts values from a Part.

diff: Int64Array

The diff values from a Part.

Implementations

impl Part

pub fn len(&self) -> usize

The length of each of the arrays in the part.

pub fn goodbytes(&self) -> usize

See ArrayOrd::goodbytes.

fn combine( parts: &[Part], combine_fn: impl FnMut(&[&dyn Array]) -> Result<ArrayRef>, ) -> Result<Self>

pub fn concat(parts: &[Part]) -> Result<Option<Self>>

Executes ::arrow::compute::concat columnwise, or returns None if no parts are given.

pub fn interleave(parts: &[Part], indices: &[(usize, usize)]) -> Result<Self>

Executes ::arrow::compute::interleave columnwise.

pub fn decode_iter<'a, K: Default + Clone + 'static, V: Default + Clone + 'static, T: Codec64, D: Codec64>( &'a self, key_schema: &'a impl Schema<K>, val_schema: &'a impl Schema<V>, ) -> Result<impl Iterator<Item = ((K, V), T, D)> + 'a>

Iterate over the contents of this part, decoding as we go.

Trait Implementations

impl Clone for Part

fn clone(&self) -> Part

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Part

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for Part

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.