Struct CountCollector 

pub struct CountCollector;

Counts rows across all partitions.

Example

use grafeo_core::execution::collector::{Collector, CountCollector};

let collector = CountCollector;
let mut pc = collector.for_partition(0);

pc.collect(&chunk1)?;
pc.collect(&chunk2)?;

let count = pc.harvest();

Trait Implementations

impl Clone for CountCollector

fn clone(&self) -> CountCollector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Collector for CountCollector

type Fruit = u64

Final result type after merging all partitions.

type PartitionCollector = CountPartitionCollector

Partition-local collector type.

fn for_partition(&self, _partition_id: usize) -> Self::PartitionCollector

Creates a collector for a single partition (called per-thread).

fn merge(&self, fruits: Vec<u64>) -> u64

Merges results from all partitions (called once at the end).

impl Debug for CountCollector

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

Formats the value using the given formatter.

impl Default for CountCollector

fn default() -> CountCollector

Returns the “default value” for a type.

impl Copy for CountCollector