Repository: samza Updated Branches: refs/heads/master 5eb470c02 -> 601c11d87
Minor: Re-word a couple of lines in javadoc with explicit notes about failures Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/601c11d8 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/601c11d8 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/601c11d8 Branch: refs/heads/master Commit: 601c11d873e3316aea538f2e0c51ac4a3c1648e7 Parents: 5eb470c Author: vjagadish1989 <jvenk...@linkedin.com> Authored: Wed May 10 12:03:53 2017 -0700 Committer: vjagadish1989 <jvenk...@linkedin.com> Committed: Wed May 10 12:03:53 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/operators/MessageStream.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/601c11d8/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java ---------------------------------------------------------------------- diff --git a/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java b/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java index 7e7a537..6d5b784 100644 --- a/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java +++ b/samza-api/src/main/java/org/apache/samza/operators/MessageStream.java @@ -104,7 +104,7 @@ public interface MessageStream<M> { * <p> * Use the {@link org.apache.samza.operators.windows.Windows} helper methods to create the appropriate windows. * <p> - * <b>Note:</b> As of version 0.13.0, messages in windows are kept in memory and may be lost in case of failures. + * <b>Note:</b> As of version 0.13.0, messages in windows are kept in memory and will be lost during restarts. * * @param window the window to group and process messages from this {@link MessageStream} * @param <K> the type of key in the message in this {@link MessageStream}. If a key is specified, @@ -121,7 +121,7 @@ public interface MessageStream<M> { * Messages in each stream are retained for the provided {@code ttl} and join results are * emitted as matches are found. * <p> - * <b>Note:</b> As of version 0.13.0, messages in joins are kept in memory and may be lost in case of failures. + * <b>Note:</b> As of version 0.13.0, messages in joins are kept in memory and will be lost during restarts. * * @param otherStream the other {@link MessageStream} to be joined with * @param joinFn the function to join messages from this and the other {@link MessageStream}