Repository: kafka Updated Branches: refs/heads/trunk b363901cb -> bd83ae6ba
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.chamb...@fundingcircle.com> Reviewers: Damian Guy <damian....@gmail.com> Closes #3888 from cddr/fix-kstream-flatMapValues-signature Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bd83ae6b Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bd83ae6b Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bd83ae6b Branch: refs/heads/trunk Commit: bd83ae6ba1f887ab112c4ccb2002633dfd387d69 Parents: b363901 Author: Andy Chambers <andy.chamb...@fundingcircle.com> Authored: Mon Sep 18 15:30:25 2017 +0100 Committer: Damian Guy <damian....@gmail.com> Committed: Mon Sep 18 15:30:25 2017 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/kafka/streams/kstream/KStream.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/bd83ae6b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java index 3a51fad..f8f99f2 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java @@ -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> { * @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}.