K
- Type of keysV
- Type of values@InterfaceStability.Unstable
public interface ReadOnlyWindowStore<K,V>
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.
|
WindowStoreIterator<V> fetch(K key, long timeFrom, long timeTo)
The time range is inclusive and applies to the starting timestamp of the window. For example, if we have the following windows:
+-------------------------------+ | key | start time | end time | +-------+------------+----------+ | A | 10 | 20 | +-------+------------+----------+ | A | 15 | 25 | +-------+------------+----------+ | A | 20 | 30 | +-------+------------+----------+ | A | 25 | 35 | +--------------------------------And we call
store.fetch("A", 10, 20)
then the results will contain the first
three windows from the table above, i.e., all those where 10 <= start time <= 20.<timestamp, value>
InvalidStateStoreException
- if the store is not initialized