Class MutableReducerState<T,​R>

  • All Implemented Interfaces:
    ReducerState<T,​R>

    public final class MutableReducerState<T,​R>
    extends java.lang.Object
    implements ReducerState<T,​R>
    INTERNAL API

    Helper class to be able to express reduce as a fold for parallel collector

    • Constructor Summary

      Constructors 
      Constructor Description
      MutableReducerState​(java.util.stream.Collector<T,​java.lang.Object,​R> collector, java.util.function.BinaryOperator<java.lang.Object> combiner, java.lang.Object reduced)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.stream.Collector<T,​java.lang.Object,​R> collector()  
      java.util.function.BinaryOperator<java.lang.Object> combiner()  
      R finish()  
      java.lang.Object reduced()  
      void reduced_$eq​(java.lang.Object x$1)  
      ReducerState<T,​R> update​(java.lang.Object batch)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • MutableReducerState

        public MutableReducerState​(java.util.stream.Collector<T,​java.lang.Object,​R> collector,
                                   java.util.function.BinaryOperator<java.lang.Object> combiner,
                                   java.lang.Object reduced)
    • Method Detail

      • collector

        public java.util.stream.Collector<T,​java.lang.Object,​R> collector()
      • combiner

        public java.util.function.BinaryOperator<java.lang.Object> combiner()
      • reduced

        public java.lang.Object reduced()
      • reduced_$eq

        public void reduced_$eq​(java.lang.Object x$1)