Uses of Class
io.streamthoughts.azkarra.api.model.KV

Packages that use KV

Package	Description
io.streamthoughts.azkarra.api.model
io.streamthoughts.azkarra.api.query
io.streamthoughts.azkarra.api.query.internal
io.streamthoughts.azkarra.api.query.result

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>>>	LocalStoreQuery.execute(KafkaStreamsContainer container)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	LocalStoreQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
static <K,V> List<KV<K,V>>	LocalStoreQuery.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>>	LocalStoreQuery.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(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	PreparedQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query locally on the specified streams instance.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchKeyRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowFetchAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowFetchKeyRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedWindowFetchQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	TimestampedWindowFetchTimeRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowGetAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchAllQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchKeyRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	WindowFetchQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	WindowFetchTimeRangeQuery.execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowGetAllQuery.execute(KafkaStreamsContainer container, 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)