kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: Update TupleForwarder comment (#4414)
Date Thu, 08 Feb 2018 01:41:44 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new e7905fc  MINOR: Update TupleForwarder comment (#4414)
e7905fc is described below

commit e7905fc7c3398490e02cddb3bcf30590b2f6d7b7
Author: Dmitry Minkovsky <dminkovsky@gmail.com>
AuthorDate: Wed Feb 7 20:41:39 2018 -0500

    MINOR: Update TupleForwarder comment (#4414)
    
    Reviewers: Guozhang Wang <wangguoz@gmail.com>
---
 .../org/apache/kafka/streams/kstream/internals/TupleForwarder.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java
index 4c02d1d..ff3ef44 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java
@@ -23,7 +23,8 @@ import org.apache.kafka.streams.state.internals.WrappedStateStore;
 
 /**
  * This class is used to determine if a processor should forward values to child nodes.
- * Forwarding only occurs when caching is not enabled.
+ * Forwarding by this class only occurs when caching is not enabled. If caching is enabled,
+ * forwarding occurs in the flush listener when the cached store flushes.
  *
  * @param <K>
  * @param <V>

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.

Mime
View raw message