Class KeyValueGetRangeQuery<K,V>
- java.lang.Object
-
- io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery<K,V>
-
- All Implemented Interfaces:
LocalStoreQuery<K,V>
public class KeyValueGetRangeQuery<K,V> extends Object implements LocalStoreQuery<K,V>
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
Try<List<KV<K,V>>>
execute(KafkaStreamsContainer container, Queried queried)
Executes this query to the specified KafkaStreams application.int
hashCode()
StoreOperation
operationType()
The operation type supported by this query.StoreType
storeType()
The storeName type on which this query can be executed.String
toString()
-
-
-
Method Detail
-
storeType
public StoreType storeType()
The storeName type on which this query can be executed.- Specified by:
storeType
in interfaceLocalStoreQuery<K,V>
- Returns:
- a new
StoreOperation
instance.
-
operationType
public StoreOperation operationType()
The operation type supported by this query.- Specified by:
operationType
in interfaceLocalStoreQuery<K,V>
- Returns:
- a new
StoreOperation
instance.
-
execute
public Try<List<KV<K,V>>> execute(KafkaStreamsContainer container, Queried queried)
Executes this query to the specified KafkaStreams application.- Specified by:
execute
in interfaceLocalStoreQuery<K,V>
- Parameters:
container
- theKafkaStreamsContainer
instance.queried
- theQueried
options.
-
-