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

Class WindowFetchQuery<K,V>

java.lang.Object

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

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

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

All Implemented Interfaces:

LocalExecutableQuery<K,V>, LocalExecutableQueryWithKey<K,K,V>, Query

public class WindowFetchQuery<K,V>
extends BaseKeyedLocalStoreQuery<K,K,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
Try<List<KV<K,V>>>	execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.

Methods inherited from class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery

equals, getKey, getKeySerializer, 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

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

execute

public Try<List<KV<K,V>>> execute(LocalStoreAccessProvider provider,
                                        long limit)

Executes this query to the specified KafkaStreams application.

Parameters:

provider - the KafkaStreamsContainer instance.

limit - the maximum number of records the result should be limited to (-1 means no limit).