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

Class SessionFetchQuery<K,V>

java.lang.Object

io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery<K,org.apache.kafka.streams.kstream.Windowed<K>,V>

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

All Implemented Interfaces:

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

public class SessionFetchQuery<K,V>
extends KeyedLocalStoreQuery<K,org.apache.kafka.streams.kstream.Windowed<K>,V>

Field Summary

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

NO_LIMIT

Method Summary

Modifier and Type	Method	Description
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	execute(KafkaStreamsContainer container, long limit)	Executes this query to the specified KafkaStreams application.
StoreOperation	operationType()	The operation type supported by this query.
StoreType	storeType()	The storeName type on which this query can be executed.

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

equals, hashCode, key, keySerializer, storeName

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

execute

Method Detail

storeType

public StoreType storeType()

The storeName type on which this query can be executed.

Returns:

a new StoreOperation instance.

operationType

public StoreOperation operationType()

The operation type supported by this query.

Returns:

a new StoreOperation instance.

execute

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

Executes this query to the specified KafkaStreams application.

Parameters:

container - the KafkaStreamsContainer instance.

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