Uses of Package
io.streamthoughts.azkarra.api.query
-
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.api.query Class Description DecorateQuery GenericQueryParams LocalExecutableQuery Default interface to execute a local state storeName.LocalPreparedQuery ALocalStoreQueryBuilder
is used to build newLocalExecutableQuery
.LocalPreparedQuery.MissingRequiredKeyError LocalStoreAccessor Default class to wrap access to local state store.LocalStoreAccessor.StoreSupplier LocalStoreAccessProvider Query QueryCall AQueryCall
is a query that has been prepared for execution.QueryCall.QueryCallFactory AQueryCallFactory
is used to create newQueryCall
.QueryOptions TheQueryOptions
cane be used to set the options to be used for querying a state store.QueryParams QueryRequest Class which is use to wrap information about the store to be query.StoreOperation StoreType The store types supported byKafkaStreams
. -
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.api.query.internal Class Description DecorateQuery LocalExecutableQuery Default interface to execute a local state storeName.LocalExecutableQueryWithKey LocalPreparedQuery ALocalStoreQueryBuilder
is used to build newLocalExecutableQuery
.LocalStoreAccessProvider Query StoreOperation -
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.api.streams Class Description QueryableKafkaStreams QueryCall.QueryCallFactory AQueryCallFactory
is used to create newQueryCall
. -
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.http.handler Class Description InteractiveQueryService AInteractiveQueryService
can be used to query aKafkaStreams
state store. -
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.http.query Class Description DecorateQuery Query QueryCall AQueryCall
is a query that has been prepared for execution.QueryOptions TheQueryOptions
cane be used to set the options to be used for querying a state store.QueryRequest Class which is use to wrap information about the store to be query. -
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.http.serialization.json Class Description QueryOptions TheQueryOptions
cane be used to set the options to be used for querying a state store.QueryRequest Class which is use to wrap information about the store to be query. -
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.runtime.query Class Description DecorateQuery InteractiveQueryService AInteractiveQueryService
can be used to query aKafkaStreams
state store.LocalExecutableQuery Default interface to execute a local state storeName.Query QueryCall AQueryCall
is a query that has been prepared for execution.QueryOptions TheQueryOptions
cane be used to set the options to be used for querying a state store.QueryRequest Class which is use to wrap information about the store to be query. -
Classes in io.streamthoughts.azkarra.api.query used by io.streamthoughts.azkarra.runtime.streams Class Description LocalStoreAccessor Default class to wrap access to local state store.LocalStoreAccessProvider QueryableKafkaStreams QueryCall.QueryCallFactory AQueryCallFactory
is used to create newQueryCall
.QueryRequest Class which is use to wrap information about the store to be query.