SessionFetchKeyRangeQuery (Azkarra Streams 0.7.0 API)

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>

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<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 java.lang.Object
clone, equals, finalize, getClass, hashCode, 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.
    
    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,
                                                                                   long limit)
```
    Executes this query to the specified KafkaStreams application.
    
    Specified by:
    
    execute in interface LocalStoreQuery<K,V>
    
    Parameters:
    
    container - the KafkaStreamsContainer instance.
    
    limit - the maximum number of records the result should be limited to (-1 means no limit).