Package io.streamthoughts.azkarra.api.query.internal

Class BaseKeyedLocalStoreQuery<K1,K2,V>

java.lang.Object

io.streamthoughts.azkarra.api.query.DecorateQuery<Query>

io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery<K1,K2,V>

All Implemented Interfaces:

LocalExecutableQuery<K2,V>, LocalExecutableQueryWithKey<K1,K2,V>, Query

Direct Known Subclasses:

KeyValueGetQuery, SessionFetchQuery, TimestampedKeyValueGetQuery, TimestampedWindowFetchQuery, WindowFetchQuery

public abstract class BaseKeyedLocalStoreQuery<K1,K2,V>
extends DecorateQuery<Query>
implements LocalExecutableQueryWithKey<K1,K2,V>

Field Summary

Fields inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

query

Fields inherited from interface io.streamthoughts.azkarra.api.query.LocalExecutableQuery

NO_LIMIT

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
K1	getKey()
org.apache.kafka.common.serialization.Serializer<K1>	getKeySerializer()
int	hashCode()

Methods inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

getParams, getStoreName, getStoreOperation, getStoreType

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.LocalExecutableQuery

execute, execute

Methods inherited from interface io.streamthoughts.azkarra.api.query.LocalExecutableQueryWithKey

hasKey

Methods inherited from interface io.streamthoughts.azkarra.api.query.Query

getParams, getStoreName, getStoreOperation, getStoreType

Method Detail

getKey

public K1 getKey()

Specified by:

getKey in interface LocalExecutableQueryWithKey<K1,K2,V>

getKeySerializer

public org.apache.kafka.common.serialization.Serializer<K1> getKeySerializer()

Specified by:

getKeySerializer in interface LocalExecutableQueryWithKey<K1,K2,V>

equals

public boolean equals(Object o)

Overrides:

equals in class DecorateQuery<Query>

hashCode

public int hashCode()

Overrides:

hashCode in class DecorateQuery<Query>