com.hazelcast.jet.counters

Interface Accumulator<V,R extends Serializable>

Type Parameters:

V - type of the input value

R - type of the output value

All Superinterfaces:

Cloneable, Serializable

All Known Subinterfaces:

SimpleAccumulator<T>

public interface Accumulator<V,R extends Serializable>
extends Serializable, Cloneable

Represents accumulator;

Method Summary

Modifier and Type	Method and Description
void	add(V value)
R	getLocalValue()
void	merge(Accumulator<V,R> other) Used by system internally to merge the collected parts of an accumulator at the end of the job.
void	resetLocal() Reset the local value.

Method Detail

add

void add(V value)

Parameters:

value - The value to add to the accumulator

getLocalValue

R getLocalValue()

Returns:

local The local value

resetLocal

void resetLocal()

Reset the local value. This only affects the current UDF context.

merge

void merge(Accumulator<V,R> other)

Used by system internally to merge the collected parts of an accumulator at the end of the job.

Parameters:

other - Reference to accumulator to merge in.