THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|
| ||||||||||
/** * Get all the key-value pairs with the given key and the time range from all * the existing windows. * <p> * The time range is inclusive and applies to the starting timestamp of the window. * For example, if we have the following windows: * <p> * <pre> * +-------------------------------+ * | key | start time | end time | * +-------+------------+----------+ * | A | 10 | 20 | * +-------+------------+----------+ * | A | 15 | 25 | * +-------+------------+----------+ * | A | 20 | 30 | * +-------+------------+----------+ * | A | 25 | 35 | * +-------------------------------- * </pre> * And we call {@code 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. * <p> * For each key, the iterator guarantees ordering of windows, starting from the oldest/earliest * available window to the newest/latest window. * * @return an iterator over key-value pairs {@code <timestamp, value>} * @throws InvalidStateStoreException if the store is not initialized */ WindowStoreIterator<V> fetch(K key, long timeFrom, long timeTo); /** * Get all the key-value pairs in the given key range and time range from all * the existing windows. * * @param from the first key in the range * @param to the last key in the range * @param timeFrom time range start (inclusive) * @param timeTo time range end (inclusive) * @return an iterator over windowed key-value pairs {@code <Windowed<K>, value>} * @throws InvalidStateStoreException if the store is not initialized * @throws NullPointerException If null is used for any key. */ KeyValueIterator<Windowed<K>, V> fetchfetchAll(K from, K to, long timeFrom, long timeTo); |
...