Interface | Description |
---|---|
ExtReadOnlyKeyValueStore<K,V> |
Extend ReadOnlyKeyValueStore functionality a bit.
|
FilterPredicate<K,V> |
Filter predicate.
|
Class | Description |
---|---|
AbstractStreamToIteratorAdapter<I,O> |
Stream to CloseableIterator
|
DistributedReadOnlyKeyValueStore<K,V> |
A
ReadOnlyKeyValueStore that is distributed among KafkaStreams processing nodes comprising
the distributed streams application. |
DistributedReadOnlyStateStore<K,V,ROS> |
A read-only StateStore base class for stores that are distributed among KafkaStreams processing
nodes comprising the distributed streams application.
|
ExtReadOnlyKeyValueStoreImpl<K,V> |
Local ExtReadOnlyKeyValueStore impl.
|
KeyValueSerde<K,V> | |
KeyValueSerde.Registry | |
KeyValueStoreGrpcImplLocalDispatcher |
Concrete implementation of
KeyValueStoreGrpc.KeyValueStoreImplBase that dispatches the
gRPC requests to the appropriately named local ReadOnlyKeyValueStore
obtained from given KafkaStreams instance. |
ReadOnlyKeyValueStoreGrpcClient<K,V> |
A gRPC based client of some remote
ReadOnlyKeyValueStore . |
StreamObserverSpliterator<T> |
A
Spliterator implementation that emits elements as they are received by the
gRPC client which calls into it with new data via StreamObserver interface. |
StreamToIteratorAdapter<K> |
Stream to CloseableIterator
|
StreamToKeyIteratorAdapter<K> |
Stream to CloseableIterator
|
StreamToKeyValueIteratorAdapter<K,V> |
An adapter that adapts
Stream <KeyValue <K, V>> to
KeyValueIterator <K, V> and lazily evaluates it when 1st queried. |
UnknownStatusDescriptionInterceptor |
A gRPC
ServerInterceptor that changes the Status of responses that have
Status.Code#UNKNOWN and don't have any Status.getDescription() but
do have the Status.getCause() such that the changed Status is obtained from
the provided map of exception root classes -> statuses augmented with the following:
cause is set to original status cause
description is set to original cause's stack trace
|
Copyright © 2020 Red Hat. All rights reserved.