Class AlwaysTrueReducer<T>

    • Constructor Detail

      • AlwaysTrueReducer

        public AlwaysTrueReducer​(T elem)
        Parameters:
        elem - Element to return from IgniteReducer.reduce() method.
    • Method Detail

      • collect

        public boolean collect​(T e)
        Collects given value. If this method returns false then IgniteReducer.reduce() will be called right away. Otherwise caller will continue collecting until all values are processed.
        Specified by:
        collect in interface IgniteReducer<T,​T>
        Parameters:
        e - Value to collect.
        Returns:
        true to continue collecting, false to instruct caller to stop collecting and call IgniteReducer.reduce() method.
      • reduce

        public T reduce()
        Reduces collected values into one.
        Specified by:
        reduce in interface IgniteReducer<T,​T>
        Returns:
        Reduced value.