Uses of Class
io.streamthoughts.azkarra.api.query.Queried

Packages that use Queried

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.query
io.streamthoughts.azkarra.api.query.internal
io.streamthoughts.azkarra.http.query
io.streamthoughts.azkarra.runtime.service

Uses of Queried in io.streamthoughts.azkarra.api

Methods in io.streamthoughts.azkarra.api with parameters of type Queried

Modifier and Type	Method	Description
<K,V> QueryResult<K,V>	AzkarraStreamsService.query(String applicationId, Query<K,V> query, QueryParams parameters, Queried options)	Executes an interactive query for the specified streams application.

Uses of Queried in io.streamthoughts.azkarra.api.query

Methods in io.streamthoughts.azkarra.api.query that return Queried

Modifier and Type	Method	Description
static Queried	Queried.immediatly()
static Queried	Queried.locally()
static Queried	Queried.with(Duration timeout)
Queried	Queried.withQueryTimeout(Duration timeout)
Queried	Queried.withRemoteAccessAllowed(boolean remoteAccessAllowed)
Queried	Queried.withRetries(int retries)
static Queried	Queried.withRetries(int retries, Duration retryBackoff)
Queried	Queried.withRetryBackoffMs(Duration retryBackoff)

Methods in io.streamthoughts.azkarra.api.query with parameters of type Queried

Modifier and Type	Method	Description
Try<List<KV<K,V>>>	LocalStoreQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<T>	LocalStoreAccessor.get(Queried options)
QueryResult<K,V>	DistributedQuery.query(KafkaStreamsContainer streams, Queried options)	Executes a state storeName query for specified arguments.
<K,V> CompletableFuture<QueryResult<K,V>>	RemoteQueryClient.query(StreamsServerInfo server, QueryInfo query, Queried options)	Executes a query to the specified server.

Uses of Queried in io.streamthoughts.azkarra.api.query.internal

Methods in io.streamthoughts.azkarra.api.query.internal with parameters of type Queried

Modifier and Type	Method	Description
Try<List<KV<String,Long>>>	KeyValueCountQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetAllQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Either<List<KV<K,V>>,List<Error>>	PreparedQuery.execute(KafkaStreamsContainer container, Queried option)	Executes this query locally on the specified streams instance.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchKeyRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchAllQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchKeyRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	WindowFetchQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	WindowFetchTimeRangeQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowGetAllQuery.execute(KafkaStreamsContainer container, Queried queried)	Executes this query to the specified KafkaStreams application.

Uses of Queried in io.streamthoughts.azkarra.http.query

Methods in io.streamthoughts.azkarra.http.query that return types with arguments of type Queried

Modifier and Type	Method	Description
static Tuple<QueryInfo,Queried>	JsonQuerySerde.deserialize(String storeName, byte[] data)

Methods in io.streamthoughts.azkarra.http.query with parameters of type Queried

Modifier and Type	Method	Description
<K,V> CompletableFuture<QueryResult<K,V>>	HttpRemoteQueryClient.query(StreamsServerInfo serverInfo, QueryInfo query, Queried options)	Executes a query to the specified server.
static String	JsonQuerySerde.serialize(QueryInfo query, Queried options)

Uses of Queried in io.streamthoughts.azkarra.runtime.service

Methods in io.streamthoughts.azkarra.runtime.service with parameters of type Queried

Modifier and Type	Method	Description
<K,V> QueryResult<K,V>	LocalAzkarraStreamsService.query(String applicationId, Query<K,V> query, QueryParams parameters, Queried options)	Executes an interactive query for the specified streams application.