You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/08/03 21:01:51 UTC

kafka git commit: MINOR: Fixed documentation for KStream left join KStream-KTable

Repository: kafka
Updated Branches:
  refs/heads/trunk 227c54fa9 -> 7d5130556


MINOR: Fixed documentation for KStream left join KStream-KTable

We are not joining in a window here.

Author: Jendrik Poloczek <je...@hivestreaming.com>

Reviewers: Guozhang Wang <wa...@gmail.com>

Closes #1692 from jpzk/trunk


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/7d513055
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/7d513055
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/7d513055

Branch: refs/heads/trunk
Commit: 7d513055671664433a783e4a62e9cbad6c44fc83
Parents: 227c54f
Author: Jendrik Poloczek <je...@hivestreaming.com>
Authored: Wed Aug 3 14:01:48 2016 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Aug 3 14:01:48 2016 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/kafka/streams/kstream/KStream.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/7d513055/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 4b0c185..032efb5 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
@@ -542,7 +542,7 @@ public interface KStream<K, V> {
      * @param <V2>      the value type of the new stream
      *
      * @return a {@link KStream} that contains join-records for each key and values computed by the given {@link ValueJoiner},
-     *         one for each matched record-pair with the same key and within the joining window intervals
+     *         one for each matched record-pair with the same key
      */
     <V1, V2> KStream<K, V2> leftJoin(KTable<K, V1> table, ValueJoiner<V, V1, V2> joiner);