Windowing

["Rick.Magnuson" <Ri...@target.com>]

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

Re: Windowing

[Thomas Weise <th...@apache.org>]

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 <tu...@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 <pa...@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 <Ri...@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
>>>
>>
>>
>

Re: Windowing

[Tushar Gosavi <tu...@datatorrent.com>]

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 <pa...@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 <Ri...@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
>>
>
>

Re: Windowing

[vikram patil <pa...@gmail.com>]

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 <Ri...@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
>