E- Type of collected values.
R- Type of reduced value.
public interface IgniteReducer<E,R> extends Serializable
boolean collect(@Nullable E e)
reduce()will be called right away. Otherwise caller will continue collecting until all values are processed.
e- Value to collect.
trueto continue collecting,
falseto instruct caller to stop collecting and call