Uses of Class
io.streamthoughts.azkarra.api.query.result.QueryResult

Packages that use QueryResult

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

Uses of QueryResult in io.streamthoughts.azkarra.api

Methods in io.streamthoughts.azkarra.api that return QueryResult

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 QueryResult in io.streamthoughts.azkarra.api.query

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

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

Methods in io.streamthoughts.azkarra.api.query that return types with arguments of type QueryResult

Modifier and Type	Method	Description
<K,V> CompletableFuture<QueryResult<K,V>>	RemoteQueryClient.query(StreamsServerInfo server, QueryInfo query, Queried options)	Executes a query to the specified server.

Uses of QueryResult in io.streamthoughts.azkarra.api.query.result

Methods in io.streamthoughts.azkarra.api.query.result that return QueryResult

Modifier and Type	Method	Description
QueryResult<K,V>	QueryResultBuilder.build()
QueryResult<K,V>	QueryResult.server(String server)	Sets the server information.
QueryResult<K,V>	QueryResult.timeout(boolean timeout)	Sets the timeout information.
QueryResult<K,V>	QueryResult.took(long took)	Sets the took information.

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

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

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.

Method parameters in io.streamthoughts.azkarra.http.query with type arguments of type QueryResult

Modifier and Type	Method	Description
HttpRemoteQueryBuilder	HttpRemoteQueryBuilder.setSerdes(Serdes<QueryResult> serdes)

Constructor parameters in io.streamthoughts.azkarra.http.query with type arguments of type QueryResult

Constructor	Description
HttpRemoteQueryClient(okhttp3.OkHttpClient httpClient, QueryURLBuilder queryURLBuilder, Serdes<QueryResult> serdes)	Creates a new HttpRemoteQueryClient instance.

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

Methods in io.streamthoughts.azkarra.runtime.service that return QueryResult

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.