Uses of Class
io.streamthoughts.azkarra.api.query.QueryRequest
-
-
Uses of QueryRequest in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query that return QueryRequest Modifier and Type Method Description QueryRequest
QueryRequest. params(QueryParams params)
QueryRequest
QueryRequest. storeName(String storeName)
QueryRequest
QueryRequest. storeOperation(StoreOperation storeOperation)
QueryRequest
QueryRequest. storeType(StoreType storeType)
Methods in io.streamthoughts.azkarra.api.query with parameters of type QueryRequest 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.<K,V>
QueryCall<K,V>QueryableKafkaStreams. newQueryCall(QueryRequest request)
Creates a newQueryCall
for specifiedQueryRequest
.<K,V>
QueryCall<K,V>QueryCall.QueryCallFactory. newQueryCall(QueryRequest request)
Creates a newQueryCall
for specifiedQueryRequest
. -
Uses of QueryRequest in io.streamthoughts.azkarra.http.query
Methods in io.streamthoughts.azkarra.http.query with parameters of type QueryRequest Modifier and Type Method Description <K,V>
QueryCall<K,V>RestApiQueryCallFactory. create(String applicationId, Endpoint localEndpoint, Endpoint remoteEndpoint, QueryRequest queryRequest)
static V1Query
V1QueryBuilder. create(QueryRequest query, QueryOptions options)
Constructors in io.streamthoughts.azkarra.http.query with parameters of type QueryRequest Constructor Description RestApiQueryCall(String applicationId, Endpoint localEndpoint, Endpoint remoteEndpoint, AzkarraV1Api api, QueryRequest request)
Creates a newRestApiQueryCall
instance. -
Uses of QueryRequest in io.streamthoughts.azkarra.http.serialization.json
Methods in io.streamthoughts.azkarra.http.serialization.json that return types with arguments of type QueryRequest 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 QueryRequest Modifier and Type Method Description static String
JsonQuerySerde. serialize(QueryRequest query, QueryOptions options)
-
Uses of QueryRequest in io.streamthoughts.azkarra.runtime.query
Methods in io.streamthoughts.azkarra.runtime.query with parameters of type QueryRequest Modifier and Type Method Description <K,V>
QueryCall<K,V>RemoteQueryCallFactory. create(String applicationServer, Endpoint localEndpoint, Endpoint remoteEndpoint, QueryRequest query)
<K,V>
QueryResult<K,V>DefaultInteractiveQueryService. execute(String applicationId, QueryRequest queryRequest, QueryOptions queryOptions)
Executes an interactive query for the specified streams application.<K,V>
QueryResult<K,V>DistributedQueryExecutionDelegatee. execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
<K,V>
QueryResult<K,V>QueryExecutionDelegatee. execute(KafkaStreamsContainer container, QueryRequest queryRequest, QueryOptions queryOptions)
-
Uses of QueryRequest in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type QueryRequest Modifier and Type Method Description <K,V>
LocalQueryCall<K,V>LocalKafkaStreamsContainer. newQueryCall(QueryRequest request)
Creates a newQueryCall
for specifiedQueryRequest
.
-