I actually found out how to do it by looking at the tests
streams.store() needs to get a WindowStoreType of QueryableStoreType
like in the following
ReadOnlyWindowStore storage = streams.store("STORAGE",
QueryableStoreTypes.windowStore());
On Wed, Feb 15, 2017 at 2:25 PM, Eno Thereska
Hi Shimi,
Did you pass in a state store name for the windowed example? E.g., if you are
doing "count" or another aggregate, you can pass in a desired state store name.
Thanks
Eno
> On 15 Feb 2017, at 00:35, Shimi Kiviti wrote:
>
> Hello,
>
> I have a code that access a state store in order to
Hello,
I have a code that access a state store in order to get the latest value of
a specific key. In a case of a regular KTable the store name is the
same store name that was passed together with the aggregator and there is
no problem accessing this store.
In the case of a Windowed KTable, I can'
