@ Override public < I > StreamConsumer < I > newInput ( Function < I , K > keyFunction , Reducer < K , I , O , A > reducer ) { return super . newInput ( keyFunction , reducer ) ; }
Creates a new input stream for this reducer