org.apache.kafka.streams.query

Class WindowKeyQuery<K,V>

java.lang.Object

org.apache.kafka.streams.query.WindowKeyQuery<K,V>

All Implemented Interfaces:

Query<WindowStoreIterator<V>>

@InterfaceStability.Evolving
public class WindowKeyQuery<K,V>
extends Object
implements Query<WindowStoreIterator<V>>

Method Summary

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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

withKeyAndWindowStartRange

public static <K,V> WindowKeyQuery<K,V> withKeyAndWindowStartRange(K key,
                                                                   Instant timeFrom,
                                                                   Instant timeTo)

getKey

public K getKey()

getTimeFrom

public Optional<Instant> getTimeFrom()

getTimeTo

public Optional<Instant> getTimeTo()

toString

public String toString()

Overrides:

toString in class Object