diff --git a/docs/streams/developer-guide/interactive-queries.html b/docs/streams/developer-guide/interactive-queries.html index 07015177563..d6cfc339b97 100644 --- a/docs/streams/developer-guide/interactive-queries.html +++ b/docs/streams/developer-guide/interactive-queries.html @@ -146,7 +146,7 @@ streams.start(); -

After the application has started, you can get access to “CountsKeyValueStore” and then query it via the ReadOnlyKeyValueStore API:

+

After the application has started, you can get access to “CountsKeyValueStore” and then query it via the ReadOnlyKeyValueStore API:

// Get the key-value store CountsKeyValueStore
 ReadOnlyKeyValueStore<String, Long> keyValueStore =
     streams.store("CountsKeyValueStore", QueryableStoreTypes.keyValueStore());
@@ -206,7 +206,7 @@
   .count(Materialized.<String, Long, WindowStore<Bytes, byte[]>as("CountsWindowStore"));
-

After the application has started, you can get access to “CountsWindowStore” and then query it via the ReadOnlyWindowStore API:

+

After the application has started, you can get access to “CountsWindowStore” and then query it via the ReadOnlyWindowStore API:

// Get the window store named "CountsWindowStore"
 ReadOnlyWindowStore<String, Long> windowStore =
     streams.store("CountsWindowStore", QueryableStoreTypes.windowStore());
@@ -259,7 +259,7 @@

To make this store queryable you must:

Here is how to implement QueryableStoreType:

@@ -281,7 +281,7 @@ multiple local instances of a particular state store. The wrapper class hides this complexity and lets you query a “logical” state store by name without having to know about all of the underlying local instances of that state store.

When implementing your wrapper class you must use the - StateStoreProvider + StateStoreProvider interface to get access to the underlying instances of your store. StateStoreProvider#stores(String storeName, QueryableStoreType<T> queryableStoreType) returns a List of state stores with the given storeName and of the type as defined by queryableStoreType.