Trait rlink::functions::schema_base::reduce::Aggregation

pub trait Aggregation: Debug {
    fn agg_type(&self) -> u8;
    fn len(&self) -> usize;
    fn record_index(&self) -> usize;
    fn reduce(
        &self, 
        writer: &mut BufferWriter<'_, '_>, 
        value_reader: Option<&mut BufferReader<'_, '_>>, 
        value_index: usize, 
        record_reader: &mut BufferReader<'_, '_>
    );
}

Required methods

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

Loading content...

Implementors

impl Aggregation for MaxF64

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

impl Aggregation for MaxI64

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

impl Aggregation for MinF64

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

impl Aggregation for MinI64

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

impl Aggregation for PctU64

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

impl Aggregation for SumF64

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

impl Aggregation for SumI64

fn agg_type(&self) -> u8

fn len(&self) -> usize

fn record_index(&self) -> usize

fn reduce(
    &self,
    writer: &mut BufferWriter<'_, '_>,
    value_reader: Option<&mut BufferReader<'_, '_>>,
    value_index: usize,
    record_reader: &mut BufferReader<'_, '_>
)

Loading content...