You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2017/09/18 14:30:30 UTC
kafka git commit: MINOR: Fix typo in mapper parameter of flatMapValues
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 <an...@fundingcircle.com>
Reviewers: Damian Guy <da...@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 <an...@fundingcircle.com>
Authored: Mon Sep 18 15:30:25 2017 +0100
Committer: Damian Guy <da...@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}.