ableegoldman commented on a change in pull request #9138: URL: https://github.com/apache/kafka/pull/9138#discussion_r476849786
########## File path: streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java ########## @@ -119,15 +118,16 @@ * <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 timeFrom time range start (inclusive) - * @param timeTo time range end (inclusive) + * @param from the first key in the range + * @param to the last key in the range + * @param timeFrom time range start (inclusive) + * @param timeTo 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 one of the given keys is {@code null} + * @throws NullPointerException if one of the given keys is {@code null} */ - @SuppressWarnings("deprecation") // note, this method must be kept if super#fetch(...) is removed + // note, this method must be kept if super#fetch(...) is removed + @SuppressWarnings("deprecation") KeyValueIterator<Windowed<K>, V> fetch(K from, K to, long timeFrom, long timeTo); Review comment: Ok, given @mjsax 's response on [KAFKA-10434](https://issues.apache.org/jira/browse/KAFKA-10434) it seems like we actually need to add the reverse variation of these long-based methods to the WindowStore API ---------------------------------------------------------------- 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