Class SessionQueryBuilder
- java.lang.Object
-
- io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
-
- All Implemented Interfaces:
QueryOperationBuilder
public class SessionQueryBuilder extends Object implements QueryOperationBuilder
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <K,V>
LocalPreparedQuery<org.apache.kafka.streams.kstream.Windowed<K>,V>fetch()
<K,V>
LocalPreparedQuery<org.apache.kafka.streams.kstream.Windowed<K>,V>fetchKeyRange()
LocalPreparedQuery
prepare(StoreOperation operation)
-
-
-
Method Detail
-
prepare
public LocalPreparedQuery prepare(StoreOperation operation)
- Specified by:
prepare
in interfaceQueryOperationBuilder
-
fetch
public <K,V> LocalPreparedQuery<org.apache.kafka.streams.kstream.Windowed<K>,V> fetch()
-
fetchKeyRange
public <K,V> LocalPreparedQuery<org.apache.kafka.streams.kstream.Windowed<K>,V> fetchKeyRange()
-
-