Im having trouble finding documentation on this new feature. Can you point
me to anything?
Specifically on how to get available "from/to" values but more generally on
how to use the "windowed" query.
On Wed, Dec 7, 2016 at 1:25 AM, Eno Thereska <eno.there...@gmail.com> wrote:
> 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?
>
>
