Package com.gengoai.stream

Interface MCounterAccumulator<T>

Type Parameters:

T - the component type parameter of the counter

All Superinterfaces:

MAccumulator<T,Counter<T>>, Serializable

All Known Implementing Classes:

LocalMCounterAccumulator, SparkMCounterAccumulator

public interface MCounterAccumulator<T>
extends MAccumulator<T,Counter<T>>

Accumulator for Counters

Author:

David B. Bracewell

Method Summary

Modifier and Type	Method	Description
void	increment(T item, double amount)	Increments the given item by the given amount.
void	merge(Counter<? extends T> counter)	Merges the given counter with this accumulator

Methods inherited from interface com.gengoai.stream.MAccumulator

add, isZero, merge, name, register, report, reset, value

Method Detail

increment

void increment(T item,
               double amount)

Increments the given item by the given amount.

Parameters:

item - the item to increment

amount - the amount to increment the item by

merge

void merge(Counter<? extends T> counter)

Merges the given counter with this accumulator

Parameters:

counter - the counter to merge