WindowRangeQuery (streams 8.3.0-ce API)

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