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.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.immediately()
static Queried	Queried.locally()
static Queried	Queried.retries(int retries, Duration retryBackoff)
static Queried	Queried.with(Duration timeout)
Queried	Queried.withLimit(Long limit)
Queried	Queried.withQueryTimeout(Duration timeout)
Queried	Queried.withRemoteAccessAllowed(boolean remoteAccessAllowed)
Queried	Queried.withRetries(int retries)
Queried	Queried.withRetryBackoffMs(Duration retryBackoff)

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

Modifier and Type	Method	Description
QueryResult<K,V>	DistributedQuery.query(KafkaStreamsContainer streams, Queried options)	Executes this interactive query for the given KafkaStreams instance.
<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.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.