Session Based Windows

2015-10-16 Thread Hamilton, Paul
Hi, I am attempting to make use of the new window APIs in streaming to implement a session based window and am not sure if the currently provided functionality handles my use case. Specifically what I want to do is something conceptually similar to a ³Sessions.withGapDuration(Š)² window in Google

Re: Session Based Windows

2015-10-21 Thread Hamilton, Paul
e let us know if you need more information. I’m always happy to help >in these interesting cases at the bleeding edge of what is possible. :-) > >Cheers, >Aljoscha > >> On 16 Oct 2015, at 19:36, Hamilton, Paul >>wrote: >> >> Hi, >> >> I am attempt

Adding Context To Logs

2016-06-02 Thread Hamilton, Paul
Hi, We are trying to rework the way our Flink jobs (and really it becomes how the operators within the jobs) log. Specifically we are trying to add contextual information to the log messages so that it is easier to filter and search for a specific jobs logs after they have been send through to