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

Class SessionFetchKeyRangeQuery<K,V>

java.lang.Object

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

All Implemented Interfaces:

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

public class SessionFetchKeyRangeQuery<K,V>
extends Object
implements LocalStoreQuery<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 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

storeType

public StoreType storeType()

The storeName type on which this query can be executed.

Specified by:

storeType in interface LocalStoreQuery<K,V>

Returns:

a new StoreOperation instance.

operationType

public StoreOperation operationType()

The operation type supported by this query.

Specified by:

operationType in interface LocalStoreQuery<K,V>

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.

Specified by:

execute in interface LocalStoreQuery<K,V>

Parameters:

container - the KafkaStreamsContainer instance.

queried - the Queried options.