Hi Jon,

This will be a windowed store. Have a look at the Jetty-server bits for 
windowedByKey:
"/windowed/{storeName}/{key}/{from}/{to}"

Thanks
Eno

> On 6 Dec 2016, at 23:33, Jon Yeargers <jon.yearg...@cedexis.com> wrote:
> 
> I copied out some of the WordCountInteractive
> <https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java>
> demo
> code to see how the REST access works. I have an aggregator
> 
> groupByKey().aggregate(LogLine::new,
>    new aggregate(),
>    TimeWindows.of(60 * 60 * 1000L),
>    collectorSerde, "agg_stream");
> 
> 
> I incorporated the Jetty-server bits from the sample. When I run it I can
> see results via the '/states/instances' entry point but nothing from the
> '/states/keyvalues/agg_stream/all'.
> 
> The aggregator is churning away so I'd assume the state store would have
> plenty of key/value pairs but it comes up empty.
> 
> What's the proper way to use this?

Reply via email to