From 3169a51d920c15b2184679d6d1930b7319ba2010 Mon Sep 17 00:00:00 2001 From: Jorge Esteban Quilcate Otoya Date: Tue, 5 Apr 2022 22:20:34 +0100 Subject: [PATCH] fix(streams): align variable names --- .../kafka/streams/state/ReadOnlySessionStore.java | 8 ++++---- .../org/apache/kafka/streams/state/SessionStore.java | 12 +++++++----- 2 files changed, 11 insertions(+), 9 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java index 4d44691992303..7fe11a6bea0e7 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java @@ -322,9 +322,9 @@ default KeyValueIterator, AGG> backwardFindSessions(final K keyFrom, /** * Get the value of key from a single session. * - * @param key the key to fetch + * @param key the key to fetch * @param sessionStartTime start timestamp of the session - * @param sessionEndTime end timestamp of the session + * @param sessionEndTime end timestamp of the session * @return The value or {@code null} if no session with the exact start and end timestamp exists * for the given key * @throws NullPointerException If {@code null} is used for any key. @@ -339,9 +339,9 @@ default AGG fetchSession(final K key, /** * Get the value of key from a single session. * - * @param key the key to fetch + * @param key the key to fetch * @param sessionStartTime start timestamp of the session - * @param sessionEndTime end timestamp of the session + * @param sessionEndTime end timestamp of the session * @return The value or {@code null} if no session with the exact start and end timestamp exists * for the given key * @throws NullPointerException If {@code null} is used for any key. 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 926cddc4d2a43..cbc1cc5b9668d 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 @@ -89,12 +89,14 @@ default KeyValueIterator, AGG> backwardFindSessions(final K keyFrom, prepareMillisCheckFailMsgPrefix(latestSessionStartTime, "latestSessionStartTime"))); } - default AGG fetchSession(final K key, final Instant earliestSessionEndTime, final Instant latestSessionStartTime) { + default AGG fetchSession(final K key, + final Instant sessionStartTime, + final Instant sessionEndTime) { return fetchSession(key, - ApiUtils.validateMillisecondInstant(earliestSessionEndTime, - prepareMillisCheckFailMsgPrefix(earliestSessionEndTime, "startTime")), - ApiUtils.validateMillisecondInstant(latestSessionStartTime, - prepareMillisCheckFailMsgPrefix(latestSessionStartTime, "endTime"))); + ApiUtils.validateMillisecondInstant(sessionStartTime, + prepareMillisCheckFailMsgPrefix(sessionStartTime, "sessionStartTime")), + ApiUtils.validateMillisecondInstant(sessionEndTime, + prepareMillisCheckFailMsgPrefix(sessionEndTime, "sessionEndTime"))); } /**