KeyValueGetQuery (Azkarra Streams 0.7.0 API)

java.lang.Object
- io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery<K,K,V>
- - io.streamthoughts.azkarra.api.query.internal.KeyValueGetQuery<K,V>

All Implemented Interfaces:: LocalStoreQuery<K,V>

public class KeyValueGetQuery<K,V>
extends KeyedLocalStoreQuery<K,K,V>

Field Summary
- Fields inherited from interface io.streamthoughts.azkarra.api.query.LocalStoreQuery
  NO_LIMIT

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Try<List<KV<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<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).