Package | Description |
---|---|
io.apicurio.registry.utils.streams.distore |
Constructor and Description |
---|
DistributedReadOnlyKeyValueStore(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo localApplicationServer,
String storeName,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valSerde,
Function<? super org.apache.kafka.streams.state.HostInfo,? extends io.grpc.Channel> grpcChannelProvider,
boolean parallel,
FilterPredicate<K,V> filterPredicate) |
ExtReadOnlyKeyValueStoreImpl(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V> delegate,
FilterPredicate<K,V> filterPredicate) |
KeyValueStoreGrpcImplLocalDispatcher(org.apache.kafka.streams.KafkaStreams streams,
KeyValueSerde.Registry keyValueSerdeRegistry,
FilterPredicate<?,?> filterPredicate) |
Copyright © 2020 Red Hat. All rights reserved.