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

Class PreparedQuery<K,V>

java.lang.Object

io.streamthoughts.azkarra.api.query.QueryInfo

io.streamthoughts.azkarra.api.query.internal.PreparedQuery<K,V>

public class PreparedQuery<K,V>
extends QueryInfo

Method Summary

Modifier and Type	Method	Description
Either<List<KV<K,V>>,List<Error>>	execute(KafkaStreamsContainer container, Queried option)	Executes this query locally on the specified streams instance.
boolean	isKeyedQuery()
K	key()
org.apache.kafka.common.serialization.Serializer<K>	keySerializer()

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

equals, hashCode, operation, parameters, storeName, toString, type

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

isKeyedQuery

public boolean isKeyedQuery()

key

public K key()

keySerializer

public org.apache.kafka.common.serialization.Serializer<K> keySerializer()

execute

public Either<List<KV<K,V>>,List<Error>> execute(KafkaStreamsContainer container,
                                                             Queried option)

Executes this query locally on the specified streams instance.

Parameters:

container - the KafkaStreamsContainer instance.

option - the Queried instance.