Uses of Class
io.streamthoughts.azkarra.api.query.result.QueryResult
-
-
Uses of QueryResult in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query that return QueryResult Modifier and Type Method Description <K,V>
QueryResult<K,V>InteractiveQueryService. execute(String applicationId, QueryRequest queryObject, QueryOptions queryOptions)
Executes an interactive query for the specified streams application.QueryResult<K,V>
QueryCall. execute(QueryOptions options)
Executes thisQueryCall
.Methods in io.streamthoughts.azkarra.api.query that return types with arguments of type QueryResult Modifier and Type Method Description CompletableFuture<QueryResult<K,V>>
QueryCall. executeAsync(QueryOptions options)
Executes thisQueryCall
asynchronously.Method parameters in io.streamthoughts.azkarra.api.query with type arguments of type QueryResult Modifier and Type Method Description void
QueryCall. executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)
Executes thisQueryCall
asynchronously. -
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 QueryResult Modifier and Type Method Description QueryResult<K,V>
RestApiQueryCall. execute(QueryOptions options)
Executes thisQueryCall
.Methods in io.streamthoughts.azkarra.http.query that return types with arguments of type QueryResult Modifier and Type Method Description CompletableFuture<QueryResult<K,V>>
RestApiQueryCall. executeAsync(QueryOptions options)
Executes thisQueryCall
asynchronously.Method parameters in io.streamthoughts.azkarra.http.query with type arguments of type QueryResult Modifier and Type Method Description void
RestApiQueryCall. executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)
Executes thisQueryCall
asynchronously.Constructor parameters in io.streamthoughts.azkarra.http.query with type arguments of type QueryResult Constructor Description AsyncQueryApiCallback(CompletableFuture<QueryResult<K,V>> completableFuture, ApiOnFailureCallback onFailureCallback)
Creates a newAsyncQueryApiCallback
instance. -
Uses of QueryResult in io.streamthoughts.azkarra.runtime.query
Methods in io.streamthoughts.azkarra.runtime.query that return QueryResult Modifier and Type Method Description <K,V>
QueryResult<K,V>DefaultInteractiveQueryService. execute(String applicationId, QueryRequest queryRequest, QueryOptions queryOptions)
Executes an interactive query for the specified streams application.QueryResult<K,V>
DistributedQueryCall. execute(QueryOptions options)
Executes thisQueryCall
.<K,V>
QueryResult<K,V>DistributedQueryExecutionDelegatee. execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
QueryResult<K,V>
EmptyQueryCall. execute(QueryOptions options)
Executes thisQueryCall
.QueryResult<K,V>
LocalQueryCall. execute(QueryOptions options)
Executes thisQueryCall
.<K,V>
QueryResult<K,V>QueryExecutionDelegatee. execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
Methods in io.streamthoughts.azkarra.runtime.query that return types with arguments of type QueryResult Modifier and Type Method Description CompletableFuture<QueryResult<K,V>>
BaseAsyncQueryCall. executeAsync(QueryOptions options)
Executes thisQueryCall
asynchronously.Method parameters in io.streamthoughts.azkarra.runtime.query with type arguments of type QueryResult Modifier and Type Method Description void
BaseAsyncQueryCall. executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)
Executes thisQueryCall
asynchronously. -
Uses of QueryResult in io.streamthoughts.azkarra.runtime.query.internal
Methods in io.streamthoughts.azkarra.runtime.query.internal that return QueryResult Modifier and Type Method Description static <K,V>
QueryResult<K,V>QueryResultUtils. buildInternalErrorResult(String localServerName, String remoteServerName, Throwable t)
static <K,V>
QueryResult<K,V>QueryResultUtils. buildNotAvailableResult(String error)
static <K,V>
QueryResult<K,V>QueryResultUtils. buildQueryResult(List<Either<SuccessResultSet<K,V>,ErrorResultSet>> results)
-