ableegoldman commented on a change in pull request #8976:
URL: https://github.com/apache/kafka/pull/8976#discussion_r462688575
##########
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
##########
@@ -136,34 +176,65 @@
* <p>
* This iterator must be closed after use.
*
- * @param from the first key in the range
- * @param to the last key in the range
- * @param fromTime time range start (inclusive)
- * @param toTime time range end (inclusive)
+ * @param from the first key in the range
+ * @param to the last key in the range
+ * @param fromTime time range start (inclusive)
+ * @param toTime time range end (inclusive)
* @return an iterator over windowed key-value pairs {@code <Windowed<K>,
value>}
* @throws InvalidStateStoreException if the store is not initialized
- * @throws NullPointerException If {@code null} is used for any key.
- * @throws IllegalArgumentException if duration is negative or can't be
represented as {@code long milliseconds}
+ * @throws NullPointerException If {@code null} is used for any key.
+ * @throws IllegalArgumentException if duration is negative or can't be
represented as {@code long milliseconds}
*/
KeyValueIterator<Windowed<K>, V> fetch(K from, K to, Instant fromTime,
Instant toTime)
throws IllegalArgumentException;
/**
- * Gets all the key-value pairs in the existing windows.
- *
- * @return an iterator over windowed key-value pairs {@code <Windowed<K>,
value>}
- * @throws InvalidStateStoreException if the store is not initialized
- */
+ * Get all the key-value pairs in the given key range and time range from
all the existing windows
+ * in backward order with respect to time (from end to beginning of time).
+ * <p>
+ * This iterator must be closed after use.
+ *
+ * @param from the first key in the range
+ * @param to the last key in the range
+ * @param fromTime time range start (inclusive)
+ * @param toTime time range end (inclusive)
+ * @return an iterator over windowed key-value pairs {@code <Windowed<K>,
value>}
+ * @throws InvalidStateStoreException if the store is not initialized
+ * @throws NullPointerException If {@code null} is used for any key.
+ * @throws IllegalArgumentException if duration is negative or can't be
represented as {@code long milliseconds}
Review comment:
nit: can we change `duration` --> `Instant`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
