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>

Method Summary

Modifier and Type	Method	Description
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	execute(KafkaStreamsContainer container, Queried queried)	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

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,
                                                                                   Queried queried)

Executes this query to the specified KafkaStreams application.

Parameters:

container - the KafkaStreamsContainer instance.

queried - the Queried options.