public class ReadOnlyKeyValueStoreGrpcClient<K,V> extends Object implements ExtReadOnlyKeyValueStore<K,V>, AutoCloseable
ReadOnlyKeyValueStore
.Constructor and Description |
---|
ReadOnlyKeyValueStoreGrpcClient(String storeName,
io.grpc.Channel channel,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valSerde) |
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() |
void |
close() |
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 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 namepublic void close()
close
in interface AutoCloseable
Copyright © 2020 Red Hat. All rights reserved.