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>>

public class WindowRangeQuery<K,V>
extends Object
implements Query<KeyValueIterator<Windowed<K>,V>>

Method Summary

Modifier and Type	Method	Description
Optional<K>	getKey()
Optional<Instant>	getTimeFrom()
Optional<Instant>	getTimeTo()
String	toString()
static <K, V> WindowRangeQuery<K,V>	withKey(K key)
static <K, V> WindowRangeQuery<K,V>	withWindowStartRange(Instant timeFrom, Instant timeTo)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

withKey

public static <K,
V> WindowRangeQuery<K,V> withKey(K key)

withWindowStartRange

public static <K,
V> WindowRangeQuery<K,V> withWindowStartRange(Instant timeFrom,
 Instant timeTo)

getKey

public Optional<K> getKey()

getTimeFrom

public Optional<Instant> getTimeFrom()

getTimeTo

public Optional<Instant> getTimeTo()

toString

public String toString()

Overrides:

toString in class Object