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

Class SessionFetchKeyRangeQuery<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

LocalExecutableQuery<org.apache.kafka.streams.kstream.Windowed<K>,V>, Query

public class SessionFetchKeyRangeQuery<K,V>
extends DecorateQuery<Query>
implements LocalExecutableQuery<org.apache.kafka.streams.kstream.Windowed<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<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.

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

equals, getParams, getStoreName, getStoreOperation, getStoreType, hashCode

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

getParams, getStoreName, getStoreOperation, getStoreType

Method Detail

execute

public Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>> execute(LocalStoreAccessProvider provider,
                                                                                   long limit)

Executes this query to the specified KafkaStreams application.

Specified by:

execute in interface LocalExecutableQuery<K,V>

Parameters:

provider - the KafkaStreamsContainer instance.

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