Repository: kafka Updated Branches: refs/heads/trunk 8068a3560 -> ef2751594
MINOR: Typo error corrected in the KStream Javadoc. Author: Kamal C <[email protected]> Reviewers: Matthias J. Sax <[email protected]>, Damian Guy <[email protected]> Closes #3520 from Kamal15/stream_doc Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ef275159 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ef275159 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ef275159 Branch: refs/heads/trunk Commit: ef275159432fd5fe88204783b621165ec39293d8 Parents: 8068a35 Author: Kamal C <[email protected]> Authored: Wed Jul 12 13:17:21 2017 -0700 Committer: Damian Guy <[email protected]> Committed: Wed Jul 12 13:17:21 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/kafka/streams/kstream/KStream.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ef275159/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 c6da8e5..ca0e916 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 @@ -122,7 +122,7 @@ public interface KStream<K, V> { * The example below normalizes the String key to upper-case letters and counts the number of token of the value string. * <pre>{@code * KStream<String, String> inputStream = builder.stream("topic"); - * KStream<Integer, String> outputStream = inputStream.map(new KeyValueMapper<String, String, KeyValue<String, Integer>> { + * KStream<String, Integer> outputStream = inputStream.map(new KeyValueMapper<String, String, KeyValue<String, Integer>> { * KeyValue<String, Integer> apply(String key, String value) { * return new KeyValue<>(key.toUpperCase(), value.split(" ").length); * } @@ -1234,7 +1234,7 @@ public interface KStream<K, V> { final Serde<VO> otherValueSerde); /** - * Join records of this stream with another {@code KStream}'s records using windowed left equi join with default + * Join records of this stream with another {@code KStream}'s records using windowed outer equi join with default * serializers and deserializers. * In contrast to {@link #join(KStream, ValueJoiner, JoinWindows) inner-join} or * {@link #leftJoin(KStream, ValueJoiner, JoinWindows) left-join}, all records from both streams will produce at @@ -1315,7 +1315,7 @@ public interface KStream<K, V> { final JoinWindows windows); /** - * Join records of this stream with another {@code KStream}'s records using windowed left equi join. + * Join records of this stream with another {@code KStream}'s records using windowed outer equi join. * In contrast to {@link #join(KStream, ValueJoiner, JoinWindows, Serde, Serde, Serde) inner-join} or * {@link #leftJoin(KStream, ValueJoiner, JoinWindows, Serde, Serde, Serde) left-join}, all records from both * streams will produce at least one output record (cf. below).
