Package com.gengoai.stream

Interface MMultiCounterAccumulator<K1,K2>

Type Parameters:

K1 - the first key type parameter

K2 - the second key type parameter

All Superinterfaces:

MAccumulator<Tuple2<K1,K2>,MultiCounter<K1,K2>>, Serializable

All Known Implementing Classes:

LocalMMultiCounterAccumulator, SparkMMultiCounterAccumulator

public interface MMultiCounterAccumulator<K1,K2>
extends MAccumulator<Tuple2<K1,K2>,MultiCounter<K1,K2>>

An accumulator for MultiCounters

Author:

David B. Bracewell

Method Summary

Modifier and Type	Method	Description
void	increment(K1 firstKey, K2 secondKey)	Increments the count of the two keys.
void	increment(K1 firstKey, K2 secondKey, double value)	Increments the count of the two keys by the given value.
void	merge(MultiCounter<K1,K2> other)	Merges the given MultiCounter with this accumulator

Methods inherited from interface com.gengoai.stream.MAccumulator

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

Method Detail

increment

void increment(K1 firstKey,
               K2 secondKey)

Increments the count of the two keys.

Parameters:

firstKey - the first key

secondKey - the second key

increment

void increment(K1 firstKey,
               K2 secondKey,
               double value)

Increments the count of the two keys by the given value.

Parameters:

firstKey - the first key

secondKey - the second key

value - the amount to increment by

merge

void merge(MultiCounter<K1,K2> other)

Merges the given MultiCounter with this accumulator

Parameters:

other - the MultiCounter to merge