Querying a store

interactive-query.java

// Get the window store named "queryStoreName"
ReadOnlyWindowStore<String, Long> windowStore =
    streams.store("queryStoreName", QueryableStoreTypes.windowStore());

// Fetch values for the key "europe" for all of the windows available in this application instance.
// To get *all* available windows we fetch windows from the beginning of time until now.
long timeFrom = 0; // beginning of time = oldest available
long timeTo = System.currentTimeMillis(); // now (in processing-time)
WindowStoreIterator<Long> iterator = windowStore.fetch("europe", timeFrom, timeTo);
while (iterator.hasNext()) {
  KeyValue<Long, Long> next = iterator.next();
  long windowTimestamp = next.key;
  System.out.println("Count of 'europe' @ time " + windowTimestamp + " is " + next.value);
}