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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Try<List<KV<K,V>>>
execute(KafkaStreamsContainer container, long limit)
Executes this query locally on the specified streams instance.boolean
isKeyedQuery()
K
key()
org.apache.kafka.common.serialization.Serializer<K>
keySerializer()
-
-
-
Method Detail
-
isKeyedQuery
public boolean isKeyedQuery()
-
key
public K key()
-
keySerializer
public org.apache.kafka.common.serialization.Serializer<K> keySerializer()
-
execute
public Try<List<KV<K,V>>> execute(KafkaStreamsContainer container, long limit)
Executes this query locally on the specified streams instance.- Parameters:
container
- theKafkaStreamsContainer
instance.
-
-