Uses of Class
io.streamthoughts.azkarra.api.query.QueryOptions
-
-
Uses of QueryOptions in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query that return QueryOptions Modifier and Type Method Description static QueryOptions
QueryOptions. immediately()
Helper method a create a newQueryOptions
with the a zerotimeout
.static QueryOptions
QueryOptions. locally()
Helper method to create a newQueryOptions
with remote access disable.static QueryOptions
QueryOptions. retries(int retries, Duration retryBackoff)
static QueryOptions
QueryOptions. with(Duration timeout)
Helper method to create a newQueryOptions
with the giventimeout
.QueryOptions
QueryOptions. withLimit(Long limit)
QueryOptions
QueryOptions. withQueryTimeout(Duration timeout)
QueryOptions
QueryOptions. withRemoteAccessAllowed(boolean remoteAccessAllowed)
QueryOptions
QueryOptions. withRetries(int retries)
QueryOptions
QueryOptions. withRetryBackoffMs(Duration retryBackoff)
Methods in io.streamthoughts.azkarra.api.query with parameters of type QueryOptions 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
.CompletableFuture<QueryResult<K,V>>
QueryCall. executeAsync(QueryOptions options)
Executes thisQueryCall
asynchronously.void
QueryCall. executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)
Executes thisQueryCall
asynchronously. -
Uses of QueryOptions in io.streamthoughts.azkarra.http.query
Methods in io.streamthoughts.azkarra.http.query with parameters of type QueryOptions Modifier and Type Method Description static V1Query
V1QueryBuilder. create(QueryRequest query, QueryOptions options)
QueryResult<K,V>
RestApiQueryCall. execute(QueryOptions options)
Executes thisQueryCall
.CompletableFuture<QueryResult<K,V>>
RestApiQueryCall. executeAsync(QueryOptions options)
Executes thisQueryCall
asynchronously.void
RestApiQueryCall. executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)
Executes thisQueryCall
asynchronously. -
Uses of QueryOptions in io.streamthoughts.azkarra.http.serialization.json
Methods in io.streamthoughts.azkarra.http.serialization.json that return types with arguments of type QueryOptions Modifier and Type Method Description static Tuple<QueryRequest,QueryOptions>
JsonQuerySerde. deserialize(String storeName, byte[] data)
Methods in io.streamthoughts.azkarra.http.serialization.json with parameters of type QueryOptions Modifier and Type Method Description static String
JsonQuerySerde. serialize(QueryRequest query, QueryOptions options)
-
Uses of QueryOptions in io.streamthoughts.azkarra.runtime.query
Methods in io.streamthoughts.azkarra.runtime.query with parameters of type QueryOptions 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)
CompletableFuture<QueryResult<K,V>>
BaseAsyncQueryCall. executeAsync(QueryOptions options)
Executes thisQueryCall
asynchronously.void
BaseAsyncQueryCall. executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)
Executes thisQueryCall
asynchronously.
-