root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Update TupleForwarder comment (#4414) 

Reviewers: Guozhang Wang <wangguoz@gmail.com>
This commit is contained in:
Dmitry Minkovsky 2018-02-07 20:41:39 -05:00 committed by Guozhang Wang
parent 67803384d9
commit e7905fc7c3
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java
View File

@ -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>