You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by shyla deshpande <de...@gmail.com> on 2018/07/11 20:50:40 UTC
How to create User Notifications/Reminder ?
I need to create User Notification/Reminder when I don’t see a specific
event (high volume) from that user for more than 2 weeks.
Should I be using windowing or CEP or ProcessFunction?
I am pretty new to Flink. Can anyone please advise me what is the best way
to solve this?
Thank you for your time.
Re: How to create User Notifications/Reminder ?
Posted by anna stax <an...@gmail.com>.
Thanks Hequn and Dawid for your input. Thanks Dawid for the link. Great
help!
On Thu, Jul 12, 2018 at 5:59 AM, Dawid Wysakowicz <
wysakowicz.dawid@gmail.com> wrote:
> Hi shyla,
>
> It should be doable with CEP. You can create pattern like:
> Pattern.begin("start").next/followedBy("end").where(...).within(/* two
> weeks*/) and subscribe for timed out events. You can check very similar
> example here[1].
>
> Best,
>
> Dawid
>
> [1] https://github.com/dataArtisans/flink-training-
> exercises/blob/master/src/main/java/com/dataartisans/
> flinktraining/exercises/datastream_java/cep/LongRidesExercise.java
>
> On 12/07/18 14:26, Hequn Cheng wrote:
>
> Hi shyla,
>
> Considering window, I think it is not very convenient. Two weeks window is
> used to process data in the recent 2 weeks while you want to process data
> beyond 2 weeks.
> I'm not familiar with CEP, but it sounds like a good idea.
>
> Best, Hequn
>
>
> On Thu, Jul 12, 2018 at 10:56 AM, shyla deshpande <
> deshpandeshyla@gmail.com> wrote:
>
>> Hi Hequen,
>>
>> I was more interested in solving using CEP.
>> I want to have a window of 2 weeks and in the Timeout Handler I want to
>> create Notification/Reminder.
>> Is this doable in Flink 1.4.2.?
>>
>> Thanks
>>
>>
>> On Wed, Jul 11, 2018 at 6:14 PM, Hequn Cheng <ch...@gmail.com>
>> wrote:
>>
>>> Hi shyla,
>>>
>>> There is a same question[1] asked two days ago. Maybe it is helpful for
>>> you. Let me know if you have any other concern.
>>> Best, Hequn
>>>
>>> [1] http://apache-flink-user-mailing-list-archive.2336050.n4
>>> .nabble.com/How-to-trigger-a-function-on-the-state-periodica
>>> lly-td21311.html
>>>
>>> On Thu, Jul 12, 2018 at 4:50 AM, shyla deshpande <
>>> deshpandeshyla@gmail.com> wrote:
>>>
>>>> I need to create User Notification/Reminder when I don’t see a specific
>>>> event (high volume) from that user for more than 2 weeks.
>>>>
>>>> Should I be using windowing or CEP or ProcessFunction?
>>>>
>>>> I am pretty new to Flink. Can anyone please advise me what is the best
>>>> way to solve this?
>>>>
>>>> Thank you for your time.
>>>>
>>>
>>>
>>
>
>
Re: How to create User Notifications/Reminder ?
Posted by shyla deshpande <de...@gmail.com>.
Thanks a lot Dawid and Hequn. Dawid, the link you provided is very useful.
Thanks
shyla
On Thu, Jul 12, 2018 at 5:59 AM, Dawid Wysakowicz <
wysakowicz.dawid@gmail.com> wrote:
> Hi shyla,
>
> It should be doable with CEP. You can create pattern like:
> Pattern.begin("start").next/followedBy("end").where(...).within(/* two
> weeks*/) and subscribe for timed out events. You can check very similar
> example here[1].
>
> Best,
>
> Dawid
>
> [1] https://github.com/dataArtisans/flink-training-
> exercises/blob/master/src/main/java/com/dataartisans/
> flinktraining/exercises/datastream_java/cep/LongRidesExercise.java
>
> On 12/07/18 14:26, Hequn Cheng wrote:
>
> Hi shyla,
>
> Considering window, I think it is not very convenient. Two weeks window is
> used to process data in the recent 2 weeks while you want to process data
> beyond 2 weeks.
> I'm not familiar with CEP, but it sounds like a good idea.
>
> Best, Hequn
>
>
> On Thu, Jul 12, 2018 at 10:56 AM, shyla deshpande <
> deshpandeshyla@gmail.com> wrote:
>
>> Hi Hequen,
>>
>> I was more interested in solving using CEP.
>> I want to have a window of 2 weeks and in the Timeout Handler I want to
>> create Notification/Reminder.
>> Is this doable in Flink 1.4.2.?
>>
>> Thanks
>>
>>
>> On Wed, Jul 11, 2018 at 6:14 PM, Hequn Cheng <ch...@gmail.com>
>> wrote:
>>
>>> Hi shyla,
>>>
>>> There is a same question[1] asked two days ago. Maybe it is helpful for
>>> you. Let me know if you have any other concern.
>>> Best, Hequn
>>>
>>> [1] http://apache-flink-user-mailing-list-archive.2336050.n4
>>> .nabble.com/How-to-trigger-a-function-on-the-state-periodica
>>> lly-td21311.html
>>>
>>> On Thu, Jul 12, 2018 at 4:50 AM, shyla deshpande <
>>> deshpandeshyla@gmail.com> wrote:
>>>
>>>> I need to create User Notification/Reminder when I don’t see a specific
>>>> event (high volume) from that user for more than 2 weeks.
>>>>
>>>> Should I be using windowing or CEP or ProcessFunction?
>>>>
>>>> I am pretty new to Flink. Can anyone please advise me what is the best
>>>> way to solve this?
>>>>
>>>> Thank you for your time.
>>>>
>>>
>>>
>>
>
>
Re: How to create User Notifications/Reminder ?
Posted by Dawid Wysakowicz <wy...@gmail.com>.
Hi shyla,
It should be doable with CEP. You can create pattern like:
Pattern.begin("start").next/followedBy("end").where(...).within(/* two
weeks*/) and subscribe for timed out events. You can check very similar
example here[1].
Best,
Dawid
[1]
https://github.com/dataArtisans/flink-training-exercises/blob/master/src/main/java/com/dataartisans/flinktraining/exercises/datastream_java/cep/LongRidesExercise.java
On 12/07/18 14:26, Hequn Cheng wrote:
> Hi shyla,
>
> Considering window, I think it is not very convenient. Two weeks
> window is used to process data in the recent 2 weeks while you want to
> process data beyond 2 weeks.
> I'm not familiar with CEP, but it sounds like a good idea.
>
> Best, Hequn
>
>
> On Thu, Jul 12, 2018 at 10:56 AM, shyla deshpande
> <deshpandeshyla@gmail.com <ma...@gmail.com>> wrote:
>
> Hi Hequen,
>
> I was more interested in solving using CEP.
> I want to have a window of 2 weeks and in the Timeout Handler I
> want to create Notification/Reminder.
> Is this doable in Flink 1.4.2.?
>
> Thanks
>
>
> On Wed, Jul 11, 2018 at 6:14 PM, Hequn Cheng <chenghequn@gmail.com
> <ma...@gmail.com>> wrote:
>
> Hi shyla,
>
> There is a same question[1] asked two days ago. Maybe it is
> helpful for you. Let me know if you have any other concern.
> Best, Hequn
>
> [1] http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-trigger-a-function-on-the-state-periodically-td21311.html
> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-trigger-a-function-on-the-state-periodically-td21311.html>
>
> On Thu, Jul 12, 2018 at 4:50 AM, shyla deshpande
> <deshpandeshyla@gmail.com <ma...@gmail.com>>
> wrote:
>
> I need to create User Notification/Reminder when I don’t
> see a specific event (high volume) from that user for more
> than 2 weeks.
>
> Should I be using windowing or CEP or ProcessFunction?
>
> I am pretty new to Flink. Can anyone please advise me what
> is the best way to solve this?
>
> Thank you for your time.
>
>
>
>
Re: How to create User Notifications/Reminder ?
Posted by Hequn Cheng <ch...@gmail.com>.
Hi shyla,
Considering window, I think it is not very convenient. Two weeks window is
used to process data in the recent 2 weeks while you want to process data
beyond 2 weeks.
I'm not familiar with CEP, but it sounds like a good idea.
Best, Hequn
On Thu, Jul 12, 2018 at 10:56 AM, shyla deshpande <de...@gmail.com>
wrote:
> Hi Hequen,
>
> I was more interested in solving using CEP.
> I want to have a window of 2 weeks and in the Timeout Handler I want to
> create Notification/Reminder.
> Is this doable in Flink 1.4.2.?
>
> Thanks
>
>
> On Wed, Jul 11, 2018 at 6:14 PM, Hequn Cheng <ch...@gmail.com> wrote:
>
>> Hi shyla,
>>
>> There is a same question[1] asked two days ago. Maybe it is helpful for
>> you. Let me know if you have any other concern.
>> Best, Hequn
>>
>> [1] http://apache-flink-user-mailing-list-archive.2336050.n4
>> .nabble.com/How-to-trigger-a-function-on-the-state-periodic
>> ally-td21311.html
>>
>> On Thu, Jul 12, 2018 at 4:50 AM, shyla deshpande <
>> deshpandeshyla@gmail.com> wrote:
>>
>>> I need to create User Notification/Reminder when I don’t see a specific
>>> event (high volume) from that user for more than 2 weeks.
>>>
>>> Should I be using windowing or CEP or ProcessFunction?
>>>
>>> I am pretty new to Flink. Can anyone please advise me what is the best
>>> way to solve this?
>>>
>>> Thank you for your time.
>>>
>>
>>
>
Re: How to create User Notifications/Reminder ?
Posted by shyla deshpande <de...@gmail.com>.
Hi Hequen,
I was more interested in solving using CEP.
I want to have a window of 2 weeks and in the Timeout Handler I want to
create Notification/Reminder.
Is this doable in Flink 1.4.2.?
Thanks
On Wed, Jul 11, 2018 at 6:14 PM, Hequn Cheng <ch...@gmail.com> wrote:
> Hi shyla,
>
> There is a same question[1] asked two days ago. Maybe it is helpful for
> you. Let me know if you have any other concern.
> Best, Hequn
>
> [1] http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/How-to-trigger-a-function-on-the-state-
> periodically-td21311.html
>
> On Thu, Jul 12, 2018 at 4:50 AM, shyla deshpande <deshpandeshyla@gmail.com
> > wrote:
>
>> I need to create User Notification/Reminder when I don’t see a specific
>> event (high volume) from that user for more than 2 weeks.
>>
>> Should I be using windowing or CEP or ProcessFunction?
>>
>> I am pretty new to Flink. Can anyone please advise me what is the best
>> way to solve this?
>>
>> Thank you for your time.
>>
>
>
Re: How to create User Notifications/Reminder ?
Posted by Hequn Cheng <ch...@gmail.com>.
Hi shyla,
There is a same question[1] asked two days ago. Maybe it is helpful for
you. Let me know if you have any other concern.
Best, Hequn
[1]
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-to-trigger-a-function-on-the-state-periodically-td21311.html
On Thu, Jul 12, 2018 at 4:50 AM, shyla deshpande <de...@gmail.com>
wrote:
> I need to create User Notification/Reminder when I don’t see a specific
> event (high volume) from that user for more than 2 weeks.
>
> Should I be using windowing or CEP or ProcessFunction?
>
> I am pretty new to Flink. Can anyone please advise me what is the best way
> to solve this?
>
> Thank you for your time.
>