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:01:51 GMT
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 <jendrik.poloczek@hivestreaming.com>

Reviewers: Guozhang Wang <wangguoz@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 <jendrik.poloczek@hivestreaming.com>
Authored: Wed Aug 3 14:01:48 2016 -0700
Committer: Guozhang Wang <wangguoz@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);
 


Mime
View raw message