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

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

Method Summary

Modifier and Type	Method	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

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

Method Details

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