Package org.apache.kafka.streams.query
Class WindowRangeQuery<K,V>
java.lang.Object
org.apache.kafka.streams.query.WindowRangeQuery<K,V>
- All Implemented Interfaces:
Query<KeyValueIterator<Windowed<K>,
V>>
-
Method Summary
Modifier and TypeMethodDescriptiongetKey()
toString()
static <K,
V> WindowRangeQuery<K, V> withKey
(K key) static <K,
V> WindowRangeQuery<K, V> withWindowStartRange
(Instant timeFrom, Instant timeTo)