kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: MINOR: Fix typo in mapper parameter of flatMapValues
Date Mon, 18 Sep 2017 14:30:30 GMT
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.chambers@fundingcircle.com>

Reviewers: Damian Guy <damian.guy@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.chambers@fundingcircle.com>
Authored: Mon Sep 18 15:30:25 2017 +0100
Committer: Damian Guy <damian.guy@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}.


Mime
View raw message