Uses of Class
io.streamthoughts.azkarra.api.query.internal.Query
-
Packages that use Query Package Description io.streamthoughts.azkarra.api io.streamthoughts.azkarra.api.query io.streamthoughts.azkarra.api.query.internal io.streamthoughts.azkarra.runtime.service -
-
Uses of Query in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api with parameters of type Query 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 Query in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query that return Query Modifier and Type Method Description abstract <K,V>
Query<K,V>StoreType. buildQuery(String storeName, StoreOperation operation)
-
Uses of Query in io.streamthoughts.azkarra.api.query.internal
Methods in io.streamthoughts.azkarra.api.query.internal that return Query Modifier and Type Method Description <K,V>
Query<K,V>KeyValueQueryBuilder. all()
<K,V>
Query<org.apache.kafka.streams.kstream.Windowed<K>,V>WindowQueryBuilder. all()
Query<String,Long>
KeyValueQueryBuilder. count()
<K,V>
Query<org.apache.kafka.streams.kstream.Windowed<K>,V>SessionQueryBuilder. fetch()
<K,V>
Query<K,V>WindowQueryBuilder. fetch()
<K,V>
Query<org.apache.kafka.streams.kstream.Windowed<K>,V>WindowQueryBuilder. fetchAll()
<K,V>
Query<org.apache.kafka.streams.kstream.Windowed<K>,V>SessionQueryBuilder. fetchKeyRange()
<K,V>
Query<org.apache.kafka.streams.kstream.Windowed<K>,V>WindowQueryBuilder. fetchKeyRange()
<K,V>
Query<Long,V>WindowQueryBuilder. fetchTimeRange()
<K,V>
Query<K,V>KeyValueQueryBuilder. get()
Query
KeyValueQueryBuilder. operation(StoreOperation operation)
Query
QueryOperationBuilder. operation(StoreOperation operation)
Query
SessionQueryBuilder. operation(StoreOperation operation)
Query
WindowQueryBuilder. operation(StoreOperation operation)
<K,V>
Query<K,V>KeyValueQueryBuilder. range()
-
Uses of Query in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service with parameters of type Query 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.
-