Package com.gengoai.stream

Interface MMapAccumulator<K,V>

Type Parameters:

K - the key type parameter

V - the value type parameter

All Superinterfaces:

MAccumulator<Tuple2<K,V>,Map<K,V>>, Serializable

All Known Implementing Classes:

LocalMMapAccumulator, SparkMMapAccumulator

public interface MMapAccumulator<K,V>
extends MAccumulator<Tuple2<K,V>,Map<K,V>>

Accumulator for Maps

Author:

David B. Bracewell

Method Summary

Modifier and Type	Method	Description
void	put(K key, V value)	Adds the given key-value pair ot the map
void	putAll(Map<? extends K,? extends V> other)	Adds all entries of the given map overriding any current entries.

Methods inherited from interface com.gengoai.stream.MAccumulator

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

Method Detail

put

void put(K key,
         V value)

Adds the given key-value pair ot the map

Parameters:

key - the key to add

value - the value to associate with the key

putAll

void putAll(Map<? extends K,? extends V> other)

Adds all entries of the given map overriding any current entries.

Parameters:

other - the map whose key-value pairs are to be added