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/07/12 20:17:25 UTC
kafka git commit: MINOR: Typo error corrected in the KStream Javadoc.
Repository: kafka
Updated Branches:
refs/heads/trunk 8068a3560 -> ef2751594
MINOR: Typo error corrected in the KStream Javadoc.
Author: Kamal C <ka...@gmail.com>
Reviewers: Matthias J. Sax <ma...@confluent.io>, Damian Guy <da...@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 <ka...@gmail.com>
Authored: Wed Jul 12 13:17:21 2017 -0700
Committer: Damian Guy <da...@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).