public class CompositeReadOnlyWindowStore<K,V> extends java.lang.Object implements ReadOnlyWindowStore<K,V>
ReadOnlyWindowStore
s found in a ProcessorTopology
Constructor and Description |
---|
CompositeReadOnlyWindowStore(StateStoreProvider provider,
QueryableStoreType<ReadOnlyWindowStore<K,V>> windowStoreType,
java.lang.String storeName) |
Modifier and Type | Method and Description |
---|---|
KeyValueIterator<Windowed<K>,V> |
all()
Gets all the key-value pairs in the existing windows.
|
WindowStoreIterator<V> |
fetch(K key,
java.time.Instant from,
java.time.Instant to)
Get all the key-value pairs with the given key and the time range from all the existing windows.
|
KeyValueIterator<Windowed<K>,V> |
fetch(K from,
K to,
java.time.Instant fromTime,
java.time.Instant toTime)
Get all the key-value pairs in the given key range and time range from all the existing windows.
|
KeyValueIterator<Windowed<K>,V> |
fetch(K from,
K to,
long timeFrom,
long timeTo)
Get all the key-value pairs in the given key range and time range from all the existing windows.
|
V |
fetch(K key,
long time)
Get the value of key from a window.
|
WindowStoreIterator<V> |
fetch(K key,
long timeFrom,
long timeTo)
Deprecated.
|
KeyValueIterator<Windowed<K>,V> |
fetchAll(java.time.Instant from,
java.time.Instant to)
Gets all the key-value pairs that belong to the windows within in the given time range.
|
KeyValueIterator<Windowed<K>,V> |
fetchAll(long timeFrom,
long timeTo)
Deprecated.
|
public CompositeReadOnlyWindowStore(StateStoreProvider provider, QueryableStoreType<ReadOnlyWindowStore<K,V>> windowStoreType, java.lang.String storeName)
public V fetch(K key, long time)
ReadOnlyWindowStore
fetch
in interface ReadOnlyWindowStore<K,V>
key
- the key to fetchtime
- start timestamp (inclusive) of the windownull
if no value is found in the window@Deprecated public WindowStoreIterator<V> fetch(K key, long timeFrom, long timeTo)
ReadOnlyWindowStore
This iterator must be closed after use.
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.
For each key, the iterator guarantees ordering of windows, starting from the oldest/earliest available window to the newest/latest window.
fetch
in interface ReadOnlyWindowStore<K,V>
key
- the key to fetchtimeFrom
- time range start (inclusive)timeTo
- time range end (inclusive)<timestamp, value>
public WindowStoreIterator<V> fetch(K key, java.time.Instant from, java.time.Instant to) throws java.lang.IllegalArgumentException
ReadOnlyWindowStore
This iterator must be closed after use.
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", Instant.ofEpochMilli(10), Instant.ofEpochMilli(20))
then the results will contain the first
three windows from the table above, i.e., all those where 10 <= start time <= 20.
For each key, the iterator guarantees ordering of windows, starting from the oldest/earliest available window to the newest/latest window.
fetch
in interface ReadOnlyWindowStore<K,V>
key
- the key to fetchfrom
- time range start (inclusive)<timestamp, value>
java.lang.IllegalArgumentException
- if duration is negative or can't be represented as long milliseconds
public KeyValueIterator<Windowed<K>,V> fetch(K from, K to, long timeFrom, long timeTo)
ReadOnlyWindowStore
This iterator must be closed after use.
fetch
in interface ReadOnlyWindowStore<K,V>
from
- the first key in the rangeto
- the last key in the rangetimeFrom
- time range start (inclusive)timeTo
- time range end (inclusive)<Windowed<K>, value>
public KeyValueIterator<Windowed<K>,V> fetch(K from, K to, java.time.Instant fromTime, java.time.Instant toTime) throws java.lang.IllegalArgumentException
ReadOnlyWindowStore
This iterator must be closed after use.
fetch
in interface ReadOnlyWindowStore<K,V>
from
- the first key in the rangeto
- the last key in the rangefromTime
- time range start (inclusive)toTime
- time range end (inclusive)<Windowed<K>, value>
java.lang.IllegalArgumentException
- if duration is negative or can't be represented as long milliseconds
public KeyValueIterator<Windowed<K>,V> all()
ReadOnlyWindowStore
all
in interface ReadOnlyWindowStore<K,V>
<Windowed<K>, value>
@Deprecated public KeyValueIterator<Windowed<K>,V> fetchAll(long timeFrom, long timeTo)
ReadOnlyWindowStore
fetchAll
in interface ReadOnlyWindowStore<K,V>
timeFrom
- the beginning of the time slot from which to search (inclusive)timeTo
- the end of the time slot from which to search (inclusive)<Windowed<K>, value>
public KeyValueIterator<Windowed<K>,V> fetchAll(java.time.Instant from, java.time.Instant to) throws java.lang.IllegalArgumentException
ReadOnlyWindowStore
fetchAll
in interface ReadOnlyWindowStore<K,V>
from
- the beginning of the time slot from which to search (inclusive)to
- the end of the time slot from which to search (inclusive)<Windowed<K>, value>
java.lang.IllegalArgumentException
- if duration is negative or can't be represented as long milliseconds