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