Package io.streamthoughts.azkarra.api.query

Interface LocalExecutableQueryWithKey<K1,K2,V>

All Superinterfaces:

LocalExecutableQuery<K2,V>, Query

All Known Implementing Classes:

BaseKeyedLocalStoreQuery, KeyValueGetQuery, SessionFetchQuery, TimestampedKeyValueGetQuery, TimestampedWindowFetchQuery, WindowFetchQuery

public interface LocalExecutableQueryWithKey<K1,K2,V>
extends LocalExecutableQuery<K2,V>

Field Summary

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

NO_LIMIT

Method Summary

Modifier and Type	Method	Description
K1	getKey()
org.apache.kafka.common.serialization.Serializer<K1>	getKeySerializer()
default boolean	hasKey()

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

execute, execute

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

getParams, getStoreName, getStoreOperation, getStoreType

Method Detail

hasKey

default boolean hasKey()

getKey

K1 getKey()

getKeySerializer

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