Skip to content
代码片段 群组 项目
未验证 提交 5a5d1c34 编辑于 作者: Jorge Esteban Quilcate Otoya's avatar Jorge Esteban Quilcate Otoya 提交者: GitHub
浏览文件

KAFKA-9929: fix: add missing default implementations (#9321)

Reviewers: A. Sophie Blee-Goldman <sophie@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
上级 4c6b9629
No related branches found
No related tags found
无相关合并请求
......@@ -155,7 +155,9 @@ public interface ReadOnlyWindowStore<K, V> {
* @throws NullPointerException if {@code null} is used for key.
* @throws IllegalArgumentException if duration is negative or can't be represented as {@code long milliseconds}
*/
WindowStoreIterator<V> backwardFetch(K key, Instant timeFrom, Instant timeTo) throws IllegalArgumentException;
default WindowStoreIterator<V> backwardFetch(K key, Instant timeFrom, Instant timeTo) throws IllegalArgumentException {
throw new UnsupportedOperationException();
}
/**
* Get all the key-value pairs in the given key range and time range from all the existing windows.
......@@ -206,8 +208,10 @@ public interface ReadOnlyWindowStore<K, V> {
* @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> backwardFetch(K keyFrom, K keyTo, Instant timeFrom, Instant timeTo)
throws IllegalArgumentException;
default KeyValueIterator<Windowed<K>, V> backwardFetch(K keyFrom, K keyTo, Instant timeFrom, Instant timeTo)
throws IllegalArgumentException {
throw new UnsupportedOperationException();
}
/**
......@@ -265,5 +269,7 @@ public interface ReadOnlyWindowStore<K, V> {
* @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> backwardFetchAll(Instant timeFrom, Instant timeTo) throws IllegalArgumentException;
default KeyValueIterator<Windowed<K>, V> backwardFetchAll(Instant timeFrom, Instant timeTo) throws IllegalArgumentException {
throw new UnsupportedOperationException();
}
}
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册