org.apache.kafka.streams.state

Interface ReadOnlyWindowStore<K,V>

Type Parameters:

K - Type of keys

V - Type of values

All Known Subinterfaces:

WindowStore<K,V>

@InterfaceStability.Unstable
public interface ReadOnlyWindowStore<K,V>

A window store that only supports read operations Implementations should be thread-safe as concurrent reads and writes are expected.

Method Summary

Methods

Modifier and Type	Method and Description
WindowStoreIterator<V>	fetch(K key, long timeFrom, long timeTo) Get all the key-value pairs with the given key and the time range from all the existing windows.

Method Detail

fetch

WindowStoreIterator<V> fetch(K key,
                           long timeFrom,
                           long timeTo)

Get all the key-value pairs with the given key and the time range from all the existing windows.

Returns:

an iterator over key-value pairs <timestamp, value>

Throws:

InvalidStateStoreException - if the store is not initialized