Repository: kafka Updated Branches: refs/heads/trunk d0e436c47 -> e31c0c9bd
MINOR: Fix typo in javadoc of `flatMapValues` Author: Michael G. Noll <[email protected]> Reviewers: Damian Guy, Matthias J. Sax, Guozhang Wang Closes #2607 from miguno/trunk-flatMapValues-docstring Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e31c0c9b Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e31c0c9b Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e31c0c9b Branch: refs/heads/trunk Commit: e31c0c9bdbad432bc21b583bd3c084f05323f642 Parents: d0e436c Author: Michael G. Noll <[email protected]> Authored: Tue Feb 28 13:30:10 2017 -0800 Committer: Guozhang Wang <[email protected]> Committed: Tue Feb 28 13:30:10 2017 -0800 ---------------------------------------------------------------------- .../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/e31c0c9b/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 46c01de..a11d8f4 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 @@ -192,7 +192,7 @@ public interface KStream<K, V> { * and emit a record {@code <word:1>} for each word. * <pre>{@code * KStream<byte[], String> inputStream = builder.stream("topic"); - * KStream<Integer, String> outputStream = inputStream.flatMap(new KeyValueMapper<byte[], String, Iterable<KeyValue<String, Integer>>> { + * KStream<String, Integer> outputStream = inputStream.flatMap(new KeyValueMapper<byte[], String, Iterable<KeyValue<String, Integer>>> { * Iterable<KeyValue<String, Integer>> apply(byte[] key, String value) { * String[] tokens = value.split(" "); * List<KeyValue<String, Integer>> result = new ArrayList<>(tokens.length); @@ -238,7 +238,7 @@ public interface KStream<K, V> { * The example below splits input records {@code <null:String>} containing sentences as values into their words. * <pre>{@code * KStream<byte[], String> inputStream = builder.stream("topic"); - * KStream<Integer, String> outputStream = inputStream.flatMap(new ValueMapper<String, Iterable<String>> { + * KStream<byte[], String> outputStream = inputStream.flatMapValues(new ValueMapper<String, Iterable<String>> { * Iterable<String> apply(String value) { * return Arrays.asList(value.split(" ")); * }
