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 <[email protected]>
AuthorDate: Wed Feb 7 20:41:39 2018 -0500
MINOR: Update TupleForwarder comment (#4414)
Reviewers: Guozhang Wang <[email protected]>
---
.../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
[email protected].
