Struct GroupCountStep 

pub struct GroupCountStep { /* private fields */ }

GroupCount step - counts by key

Implementations

impl GroupCountStep

pub fn new() -> Self

Create groupCount() step

Trait Implementations

impl BarrierStep for GroupCountStep

fn add_to_barrier(&mut self, traverser: Traverser)

Add traverser to barrier

fn flush_barrier(&mut self) -> Vec<Traverser>

Flush barrier and produce results

fn has_data(&self) -> bool

Check if barrier has accumulated data

fn is_ready(&self) -> bool

Check if barrier is ready to flush

impl Clone for GroupCountStep

fn clone(&self) -> GroupCountStep

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GroupCountStep

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

Formats the value using the given formatter.

impl Default for GroupCountStep

fn default() -> Self

Returns the “default value” for a type.

impl Step for GroupCountStep

fn id(&self) -> &str

Step identifier (unique in traversal)

fn name(&self) -> &str

Human-readable name

fn labels(&self) -> &[String]

Labels assigned to this step

fn add_label(&mut self, label: String)

Add a label to this step

fn requirements(&self) -> &[TraverserRequirement]

Requirements this step declares

fn process_traverser(&self, traverser: Traverser) -> StepResult

Process a single traverser (standard algorithm)

fn reset(&mut self)

Reset step state for reuse

fn clone_step(&self) -> Box<dyn Step>

Clone as trait object

fn as_any(&self) -> &dyn Any

Downcast to concrete type

fn as_any_mut(&mut self) -> &mut dyn Any

Downcast to mutable concrete type