public class ExtReadOnlyKeyValueStoreImpl<K,V> extends Object implements ExtReadOnlyKeyValueStore<K,V>
Constructor and Description |
---|
ExtReadOnlyKeyValueStoreImpl(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V> delegate,
FilterPredicate<K,V> filterPredicate) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.streams.state.KeyValueIterator<K,V> |
all() |
Stream<K> |
allKeys()
All keys, as a stream.
|
long |
approximateNumEntries() |
Stream<org.apache.kafka.streams.KeyValue<K,V>> |
filter(String filter,
String over)
Get filtered stream.
|
V |
get(K key) |
org.apache.kafka.streams.state.KeyValueIterator<K,V> |
range(K from,
K to) |
public ExtReadOnlyKeyValueStoreImpl(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V> delegate, FilterPredicate<K,V> filterPredicate)
public Stream<K> allKeys()
ExtReadOnlyKeyValueStore
allKeys
in interface ExtReadOnlyKeyValueStore<K,V>
public Stream<org.apache.kafka.streams.KeyValue<K,V>> filter(String filter, String over)
ExtReadOnlyKeyValueStore
filter
in interface ExtReadOnlyKeyValueStore<K,V>
filter
- the string filterover
- the search over enum nameCopyright © 2020 Red Hat. All rights reserved.