public class IntSumReducer extends Object implements IgniteReducer<Integer,Integer>
public boolean collect(Integer e)
false then IgniteReducer.reduce()
will be called right away. Otherwise caller will continue collecting until all
values are processed.collect in interface IgniteReducer<Integer,Integer>e - Value to collect.true to continue collecting, false to instruct caller to stop
collecting and call IgniteReducer.reduce() method.public Integer reduce()
reduce in interface IgniteReducer<Integer,Integer>
Follow @ApacheIgnite
Ignite Fabric : ver. 2.2.0 Release Date : September 15 2017