code: @Override
  	public <I> StreamConsumer<I> newInput(Function<I, K> keyFunction, Reducer<K, I, O, A> reducer) {
  		return super.newInput(keyFunction, reducer);
  	}
docs: Creates a new input stream for this reducer
  
  @param keyFunction function for counting key
  @param reducer     reducer witch will performs actions with its stream
  @param <I>         type of input data
  @return new consumer