code: public static <K, O, A> StreamReducer<K, O, A> create(Comparator<K> keyComparator) {
  		return new StreamReducer<>(keyComparator);
  	}
docs: Creates a new instance of StreamReducer
  
  @param keyComparator comparator for compare keys