kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Fixed documentation for KStream left join KStream-KTable
Date Wed, 03 Aug 2016 21:02:04 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 1b333c23f -> 127bb7fca


MINOR: Fixed documentation for KStream left join KStream-KTable

We are not joining in a window here.

Author: Jendrik Poloczek <jendrik.poloczek@hivestreaming.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #1692 from jpzk/trunk

(cherry picked from commit 7d513055671664433a783e4a62e9cbad6c44fc83)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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

Branch: refs/heads/0.10.0
Commit: 127bb7fca2b55b13ceb3e94662b0be1f091b9da1
Parents: 1b333c2
Author: Jendrik Poloczek <jendrik.poloczek@hivestreaming.com>
Authored: Wed Aug 3 14:01:48 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Wed Aug 3 14:02:00 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/127bb7fc/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 a1ecfa4..6cf0c4a 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
@@ -453,7 +453,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);
 


Mime
View raw message