WindowKeyQuery (streams 8.2.0-0-ce API)

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