Class KeyedLocalStoreQuery<T,K,V>
- java.lang.Object
-
- io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery<T,K,V>
-
- All Implemented Interfaces:
LocalStoreQuery<K,V>
- Direct Known Subclasses:
KeyValueGetQuery
,SessionFetchQuery
,TimestampedKeyValueGetQuery
,TimestampedWindowFetchQuery
,WindowFetchQuery
public abstract class KeyedLocalStoreQuery<T,K,V> extends Object implements LocalStoreQuery<K,V>
-
-
Field Summary
-
Fields inherited from interface io.streamthoughts.azkarra.api.query.LocalStoreQuery
NO_LIMIT
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
T
key()
org.apache.kafka.common.serialization.Serializer<T>
keySerializer()
String
storeName()
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.streamthoughts.azkarra.api.query.LocalStoreQuery
execute, execute, operationType, storeType
-
-