Package org.apache.ignite.lang
Interface IgniteReducer<E,R>
- 
- Type Parameters:
- E- Type of collected values.
- R- Type of reduced value.
 - All Superinterfaces:
- Serializable
 
 public interface IgniteReducer<E,R> extends Serializable Defines generic reducer that collects multiple values and reduces them into one. Reducers are useful in computations when results from multiple remote jobs need to be reduced into one, e.g.IgniteCompute.call(Collection, IgniteReducer)method.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description booleancollect(E e)Collects given value.Rreduce()Reduces collected values into one.
 
- 
- 
- 
Method Detail- 
collectboolean collect(@Nullable E e)Collects given value. If this method returnsfalsethenreduce()will be called right away. Otherwise caller will continue collecting until all values are processed.- Parameters:
- e- Value to collect.
- Returns:
- trueto continue collecting,- falseto instruct caller to stop collecting and call- reduce()method.
 
 - 
reduceR reduce() Reduces collected values into one.- Returns:
- Reduced value.
 
 
- 
 
-