Uses of Interface
io.streamthoughts.azkarra.api.query.LocalExecutableQuery
-
Packages that use LocalExecutableQuery Package Description io.streamthoughts.azkarra.api.query io.streamthoughts.azkarra.api.query.internal io.streamthoughts.azkarra.runtime.query -
-
Uses of LocalExecutableQuery in io.streamthoughts.azkarra.api.query
Subinterfaces of LocalExecutableQuery in io.streamthoughts.azkarra.api.query Modifier and Type Interface Description interface
LocalExecutableQueryWithKey<K1,K2,V>
Classes in io.streamthoughts.azkarra.api.query that implement LocalExecutableQuery Modifier and Type Class Description class
LoggingFailureLocalExecutableQuery<K,V>
Methods in io.streamthoughts.azkarra.api.query that return LocalExecutableQuery Modifier and Type Method Description LocalExecutableQuery<K,V>
LocalPreparedQuery. compile(QueryParams params)
Builds a newLocalExecutableQuery
based on the givenQuery
.<K,V>
LocalExecutableQuery<K,V>QueryRequest. compile()
Constructors in io.streamthoughts.azkarra.api.query with parameters of type LocalExecutableQuery Constructor Description LoggingFailureLocalExecutableQuery(LocalExecutableQuery<K,V> query)
Creates a newLoggingFailureLocalExecutableQuery
instance. -
Uses of LocalExecutableQuery in io.streamthoughts.azkarra.api.query.internal
Classes in io.streamthoughts.azkarra.api.query.internal that implement LocalExecutableQuery Modifier and Type Class Description class
BaseKeyedLocalStoreQuery<K1,K2,V>
class
KeyValueCountQuery
class
KeyValueGetAllQuery<K,V>
class
KeyValueGetQuery<K,V>
class
KeyValueGetRangeQuery<K,V>
class
SessionFetchKeyRangeQuery<K,V>
class
SessionFetchQuery<K,V>
class
TimestampedKeyValueGetAllQuery<K,V>
class
TimestampedKeyValueGetQuery<K,V>
class
TimestampedKeyValueGetRangeQuery<K,V>
class
TimestampedWindowFetchAllQuery<K,V>
class
TimestampedWindowFetchKeyRangeQuery<K,V>
class
TimestampedWindowFetchQuery<K,V>
class
TimestampedWindowFetchTimeRangeQuery<K,V>
class
TimestampedWindowGetAllQuery<K,V>
class
WindowFetchAllQuery<K,V>
class
WindowFetchKeyRangeQuery<K,V>
class
WindowFetchQuery<K,V>
class
WindowFetchTimeRangeQuery<K,V>
class
WindowGetAllQuery<K,V>
-
Uses of LocalExecutableQuery in io.streamthoughts.azkarra.runtime.query
Constructors in io.streamthoughts.azkarra.runtime.query with parameters of type LocalExecutableQuery Constructor Description DistributedQueryCall(LocalExecutableQuery<K,V> query, LocalKafkaStreamsContainer container, RemoteQueryCallFactory callFactory)
Creates a newDecorateQuery
instance.LocalQueryCall(LocalKafkaStreamsContainer container, LocalExecutableQuery<K,V> query)
Creates a newDecorateQuery
instance.
-