This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new ca834d11746 MINOR: remove incorrect deprecated annotations from
internal Streams classes (#19195)
ca834d11746 is described below
commit ca834d11746c97b16f0e6b0c288e2398335d21db
Author: Alieh Saeedi <[email protected]>
AuthorDate: Thu Mar 13 01:49:00 2025 +0100
MINOR: remove incorrect deprecated annotations from internal Streams
classes (#19195)
Reviewers: Matthias J. Sax <[email protected]>
---
.../kafka/streams/processor/internals/AbstractReadOnlyDecorator.java | 3 ---
.../org/apache/kafka/streams/state/internals/InMemoryWindowStore.java | 3 ---
2 files changed, 6 deletions(-)
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 12326ef5721..c8b683aa96c 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 @@ abstract class AbstractReadOnlyDecorator<T extends
StateStore, K, V> extends Wra
}
@Override
- @Deprecated
public WindowStoreIterator<V> fetch(final K key,
final long timeFrom,
final long timeTo) {
@@ -221,7 +220,6 @@ abstract class AbstractReadOnlyDecorator<T extends
StateStore, K, V> extends Wra
}
@Override
- @Deprecated
public KeyValueIterator<Windowed<K>, V> fetch(final K keyFrom,
final K keyTo,
final long timeFrom,
@@ -248,7 +246,6 @@ abstract class AbstractReadOnlyDecorator<T extends
StateStore, K, V> extends Wra
}
@Override
- @Deprecated
public KeyValueIterator<Windowed<K>, 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 4b224926f50..d3d5ba4a20d 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 class InMemoryWindowStore implements
WindowStore<Bytes, byte[]> {
}
}
- @Deprecated
@Override
public WindowStoreIterator<byte[]> fetch(final Bytes key, final long
timeFrom, final long timeTo) {
return fetch(key, timeFrom, timeTo, true);
@@ -236,7 +235,6 @@ public class InMemoryWindowStore implements
WindowStore<Bytes, byte[]> {
}
}
- @Deprecated
@Override
public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes keyFrom,
final Bytes keyTo,
@@ -294,7 +292,6 @@ public class InMemoryWindowStore implements
WindowStore<Bytes, byte[]> {
}
}
- @Deprecated
@Override
public KeyValueIterator<Windowed<Bytes>, byte[]> fetchAll(final long
timeFrom, final long timeTo) {
return fetchAll(timeFrom, timeTo, true);