Here is an example that uses the window operator to compute top words and time series from Tweets (and optionally outputs the results to websocket):
https://github.com/tweise/apex-samples/tree/master/twitter On Thu, Jun 8, 2017 at 11:11 AM, Tushar Gosavi <tus...@datatorrent.com> wrote: > You can find more apex example applications in malhar repository > https://github.com/apache/apex-malhar/tree/master/examples > > For time based windows aggregation you can take a look at yahoo streaming > benchmark implemented in Apex. > https://github.com/yahoo/streaming-benchmarks/blob/ > master/apex-benchmarks/src/main/java/apex/benchmark/ > ApplicationDimensionComputation.java > > Regards, > - Tushar. > > > On Thu, Jun 8, 2017 at 10:05 PM, vikram patil <patilvik...@gmail.com> > wrote: > >> Hi Rick, >> >> Hopefully this will help you, if you haven't already looked at it. >> https://apex.apache.org/docs/malhar/operators/windowedOperator/ >> >> Regards, >> Vikram >> >> On Thu, Jun 8, 2017 at 10:03 PM, Rick.Magnuson <rick.magnu...@target.com> >> wrote: >> >>> Does anyone have any documentation on using Windowing with Apache Apex? >>> I’ve checked out the documentation on the Apache Apex website but was >>> hoping to find some additional resources. Also, if anyone has any examples >>> outside of the word count example provided by Apex, I would greatly >>> appreciate that too. Thanks, >>> >>> >>> >>> Rick Magnuson | Lead Data Engineer | ¤Target | 1000 Nicollet Mall | >>> Minneapolis, MN 55403 >>> >> >> >
