diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java index 12326ef572114..c8b683aa96cba 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java @@ -206,7 +206,6 @@ public V fetch(final K key, } @Override - @Deprecated public WindowStoreIterator fetch(final K key, final long timeFrom, final long timeTo) { @@ -221,7 +220,6 @@ public WindowStoreIterator backwardFetch(final K key, } @Override - @Deprecated public KeyValueIterator, V> fetch(final K keyFrom, final K keyTo, final long timeFrom, @@ -248,7 +246,6 @@ public KeyValueIterator, V> backwardAll() { } @Override - @Deprecated public KeyValueIterator, V> fetchAll(final long timeFrom, final long timeTo) { return wrapped().fetchAll(timeFrom, timeTo); diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java index 4b224926f506c..d3d5ba4a20d44 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java @@ -196,7 +196,6 @@ public byte[] fetch(final Bytes key, final long windowStartTimestamp) { } } - @Deprecated @Override public WindowStoreIterator fetch(final Bytes key, final long timeFrom, final long timeTo) { return fetch(key, timeFrom, timeTo, true); @@ -236,7 +235,6 @@ WindowStoreIterator fetch(final Bytes key, final long timeFrom, final lo } } - @Deprecated @Override public KeyValueIterator, byte[]> fetch(final Bytes keyFrom, final Bytes keyTo, @@ -294,7 +292,6 @@ KeyValueIterator, byte[]> fetch(final Bytes from, } } - @Deprecated @Override public KeyValueIterator, byte[]> fetchAll(final long timeFrom, final long timeTo) { return fetchAll(timeFrom, timeTo, true);