Uses of Class
io.streamthoughts.azkarra.api.model.KV
-
-
Uses of KV in io.streamthoughts.azkarra.api.events
Methods in io.streamthoughts.azkarra.api.events that return KV Modifier and Type Method Description KV<K,V>
BasicBlockingRecordQueue. poll()
KV<K,V>
BasicBlockingRecordQueue. poll(Duration timeout)
KV<K,V>
BlockingRecordQueue. poll()
KV<K,V>
BlockingRecordQueue. poll(Duration tmaxBlockingTimeimeout)
KV<K,V>
DelegateBlockingRecordQueue. poll()
KV<K,V>
DelegateBlockingRecordQueue. poll(Duration timeout)
Methods in io.streamthoughts.azkarra.api.events with parameters of type KV Modifier and Type Method Description void
BasicBlockingRecordQueue. send(KV<K,V> record)
Sends a key-value record into this queue.void
BlockingRecordQueue. send(KV<K,V> kv)
Sends a key-value record into this queue.void
DelegateBlockingRecordQueue. send(KV<K,V> record)
Sends a key-value record into this queue.void
EventStream. send(KV<K,V> kv)
Sends a null-key value record into this stream.<K,V>
voidEventStreamSupport. send(String type, KV<K,V> kv)
Sends a null-key value record into into the given stream.Method parameters in io.streamthoughts.azkarra.api.events with type arguments of type KV Modifier and Type Method Description void
BasicBlockingRecordQueue. drainTo(Collection<? super KV<K,V>> collection)
void
BlockingRecordQueue. drainTo(Collection<? super KV<K,V>> collection)
void
DelegateBlockingRecordQueue. drainTo(Collection<? super KV<K,V>> collection)
-
Uses of KV in io.streamthoughts.azkarra.api.events.reactive
Method parameters in io.streamthoughts.azkarra.api.events.reactive with type arguments of type KV Modifier and Type Method Description void
AsyncMulticastEventStreamPublisher. subscribe(Flow.Subscriber<? super KV<K,V>> subscriber)
void
EventStreamPublisher. subscribe(Flow.Subscriber<? super KV<K,V>> subscriber)
-
Uses of KV in io.streamthoughts.azkarra.api.model
Methods in io.streamthoughts.azkarra.api.model that return KV Modifier and Type Method Description static <K,V>
KV<K,V>KV. of(K key, V value)
static <K,V>
KV<K,V>KV. of(K key, V value, Long timestamp)
static <K,V>
KV<K,V>KV. of(org.apache.kafka.streams.KeyValue<K,V> kv)
KV<V,K>
KV. swap()
Swaps the key and value.Methods in io.streamthoughts.azkarra.api.model with parameters of type KV Modifier and Type Method Description int
KV. compareTo(KV<K,V> that)
-
Uses of KV in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query that return types with arguments of type KV Modifier and Type Method Description default Try<List<KV<K,V>>>
LocalExecutableQuery. execute(LocalStoreAccessProvider provider)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
LocalExecutableQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
LoggingFailureLocalExecutableQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.static <K,V>
List<KV<K,V>>LocalExecutableQuery. toKeyValueAndTimestampListAndClose(org.apache.kafka.streams.state.KeyValueIterator<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>> it, long limit)
static <K,V>
List<KV<K,V>>LocalExecutableQuery. toKeyValueListAndClose(org.apache.kafka.streams.state.KeyValueIterator<K,V> it, long limit)
-
Uses of KV in io.streamthoughts.azkarra.api.query.internal
Methods in io.streamthoughts.azkarra.api.query.internal that return types with arguments of type KV Modifier and Type Method Description Try<List<KV<String,Long>>>
KeyValueCountQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
KeyValueGetAllQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
KeyValueGetQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
KeyValueGetRangeQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
SessionFetchKeyRangeQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
SessionFetchQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
TimestampedKeyValueGetAllQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
TimestampedKeyValueGetQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
TimestampedKeyValueGetRangeQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
TimestampedWindowFetchAllQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
TimestampedWindowFetchKeyRangeQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
TimestampedWindowFetchQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<Long,V>>>
TimestampedWindowFetchTimeRangeQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
TimestampedWindowGetAllQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
WindowFetchAllQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
WindowFetchKeyRangeQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<K,V>>>
WindowFetchQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<Long,V>>>
WindowFetchTimeRangeQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application.Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>
WindowGetAllQuery. execute(LocalStoreAccessProvider provider, long limit)
Executes this query to the specified KafkaStreams application. -
Uses of KV in io.streamthoughts.azkarra.api.query.result
Methods in io.streamthoughts.azkarra.api.query.result that return types with arguments of type KV Modifier and Type Method Description List<KV<K,V>>
SuccessResultSet. getRecords()
Constructor parameters in io.streamthoughts.azkarra.api.query.result with type arguments of type KV Constructor Description SuccessResultSet(String server, boolean remote, List<KV<K,V>> records)
-
Uses of KV in io.streamthoughts.azkarra.http.sse
Methods in io.streamthoughts.azkarra.http.sse that return KV Modifier and Type Method Description KV
ServerSentEventSubscriber.StreamedEvent. getRecord()
Methods in io.streamthoughts.azkarra.http.sse with parameters of type KV Modifier and Type Method Description void
ServerSentEventSubscriber. onNext(KV<K,V> record)
static ServerSentEventSubscriber.StreamedEvent
ServerSentEventSubscriber.StreamedEvent. record(KV<?,?> record)
Constructors in io.streamthoughts.azkarra.http.sse with parameters of type KV Constructor Description StreamedEvent(KV<?,?> record)
-