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: Typo error corrected in the KStream Javadoc.
Date Wed, 12 Jul 2017 20:17:25 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 8068a3560 -> ef2751594


MINOR: Typo error corrected in the KStream Javadoc.

Author: Kamal C <kamal.chandraprakash@gmail.com>

Reviewers: Matthias J. Sax <matthias@confluent.io>, Damian Guy <damian.guy@gmail.com>

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 <kamal.chandraprakash@gmail.com>
Authored: Wed Jul 12 13:17:21 2017 -0700
Committer: Damian Guy <damian.guy@gmail.com>
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).


Mime
View raw message