Browse Source

MINOR: Fix typo in mapper parameter of flatMapValues

The parameter is already called `mapper` in the KStreamImpl class. I think it was probably named `processor` here because it was copy/pasted from some other signature. This sees trivial enough to not require a jira as per the contribution guidelines.

Author: Andy Chambers <andy.chambers@fundingcircle.com>

Reviewers: Damian Guy <damian.guy@gmail.com>

Closes #3888 from cddr/fix-kstream-flatMapValues-signature
pull/3890/merge
Andy Chambers 7 years ago committed by Damian Guy
parent
commit
bd83ae6ba1
  1. 4
      streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java

4
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java

@ -252,7 +252,7 @@ public interface KStream<K, V> { @@ -252,7 +252,7 @@ public interface KStream<K, V> {
* Thus, <em>no</em> internal data redistribution is required if a key based operator (like an aggregation or join)
* is applied to the result {@code KStream}. (cf. {@link #flatMap(KeyValueMapper)})
*
* @param processor a {@link ValueMapper} the computes the new output values
* @param mapper a {@link ValueMapper} the computes the new output values
* @param <VR> the value type of the result stream
* @return a {@code KStream} that contains more or less records with unmodified keys and new values of different type
* @see #selectKey(KeyValueMapper)
@ -262,7 +262,7 @@ public interface KStream<K, V> { @@ -262,7 +262,7 @@ public interface KStream<K, V> {
* @see #transform(TransformerSupplier, String...)
* @see #transformValues(ValueTransformerSupplier, String...)
*/
<VR> KStream<K, VR> flatMapValues(final ValueMapper<? super V, ? extends Iterable<? extends VR>> processor);
<VR> KStream<K, VR> flatMapValues(final ValueMapper<? super V, ? extends Iterable<? extends VR>> mapper);
/**
* Print the records of this stream to {@code System.out}.

Loading…
Cancel
Save