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: fix javadoc comment of Transformer
Date Fri, 21 Apr 2017 20:27:14 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 3d8506a3a -> d7b5eadb9


MINOR: fix javadoc comment of Transformer

Here's where it's called:
https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransform.java#L64-L67

Author: mihbor <mbor81@gmail.com>

Reviewers: Matthias J. Sax, Damian Guy, Guozhang Wang

Closes #2884 from mihbor/patch-3


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

Branch: refs/heads/trunk
Commit: d7b5eadb92e514857754f8599f3d902093651f25
Parents: 3d8506a
Author: Michal Borowiecki <mbor81@gmail.com>
Authored: Fri Apr 21 13:27:11 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Apr 21 13:27:11 2017 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/streams/kstream/Transformer.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/d7b5eadb/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
index 427054e..f0a322e 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
@@ -18,7 +18,6 @@ package org.apache.kafka.streams.kstream;
 
 import org.apache.kafka.common.annotation.InterfaceStability;
 import org.apache.kafka.streams.KeyValue;
-import org.apache.kafka.streams.errors.StreamsException;
 import org.apache.kafka.streams.processor.ProcessorContext;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TimestampExtractor;
@@ -96,7 +95,7 @@ public interface Transformer<K, V, R> {
      * and not based on wall-clock time.
      *
      * @param timestamp the stream time when {@code punctuate} is being called
-     * @return must return {@code null}&mdash;otherwise, a {@link StreamsException exception}
will be thrown
+     * @return new {@link KeyValue} pair to be forwarded to down stream&mdash;if {@code
null} will not be forwarded
      */
     R punctuate(final long timestamp);
 


Mime
View raw message