Interface LocalStoreQuery<K,V>
-
- All Known Implementing Classes:
KeyedLocalStoreQuery
,KeyValueCountQuery
,KeyValueGetAllQuery
,KeyValueGetQuery
,KeyValueGetRangeQuery
,SessionFetchKeyRangeQuery
,SessionFetchQuery
,WindowFetchAllQuery
,WindowFetchKeyRangeQuery
,WindowFetchQuery
,WindowFetchTimeRangeQuery
,WindowGetAllQuery
public interface LocalStoreQuery<K,V>
Default interface to execute a local state storeName.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description Try<List<KV<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.static <K,V>
List<KV<K,V>>toKeyValueListAndClose(org.apache.kafka.streams.state.KeyValueIterator<K,V> it)
-
-
-
Method Detail
-
storeType
StoreType storeType()
The storeName type on which this query can be executed.- Returns:
- a new
StoreOperation
instance.
-
operationType
StoreOperation operationType()
The operation type supported by this query.- Returns:
- a new
StoreOperation
instance.
-
execute
Try<List<KV<K,V>>> execute(KafkaStreamsContainer container, Queried queried)
Executes this query to the specified KafkaStreams application.- Parameters:
container
- theKafkaStreamsContainer
instance.queried
- theQueried
options.
-
-