Class ReducerState<T,​R>

  • public final class ReducerState<T,​R>
    extends java.lang.Object

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

    • Constructor Summary

      Constructor Description
      ReducerState​(<T,​java.lang.Object,​R> collector)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description<T,​java.lang.Object,​R> collector()  
      R finish()  
      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

      • ReducerState

        public ReducerState​(<T,​java.lang.Object,​R> collector)
    • Method Detail

      • collector

        public<T,​java.lang.Object,​R> collector()
      • finish

        public R finish()
      • update

        public ReducerState<T,​R> update​(java.lang.Object batch)