You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/04/21 20:25:16 UTC
kafka git commit: KAFKA-5090: Fix Kafka Streams
SessionStore.findSessions javadoc broken
Repository: kafka
Updated Branches:
refs/heads/trunk cba0094f5 -> 3d8506a3a
KAFKA-5090: Fix Kafka Streams SessionStore.findSessions javadoc broken
Author: mihbor <mb...@gmail.com>
Reviewers: Matthias J. Sax, Guozhang Wang
Closes #2874 from mihbor/patch-1
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3d8506a3
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3d8506a3
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3d8506a3
Branch: refs/heads/trunk
Commit: 3d8506a3ac5e4176ea1f2f0be97bef2712f46464
Parents: cba0094
Author: Michal Borowiecki <mb...@gmail.com>
Authored: Fri Apr 21 13:25:12 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Fri Apr 21 13:25:12 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/kafka/streams/state/SessionStore.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/3d8506a3/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java b/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java
index 16fa271..8ae5c06 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java
@@ -27,8 +27,8 @@ import org.apache.kafka.streams.processor.StateStore;
public interface SessionStore<K, AGG> extends StateStore, ReadOnlySessionStore<K, AGG> {
/**
- * Fetch any sessions with the matching key and the sessions end is &le earliestEndTime and the sessions
- * start is &ge latestStartTime
+ * Fetch any sessions with the matching key and the sessions end is ≥ earliestSessionEndTime and the sessions
+ * start is ≤ latestSessionStartTime
*/
KeyValueIterator<Windowed<K>, AGG> findSessions(final K key, long earliestSessionEndTime, final long latestSessionStartTime);