Re: Timer support in Flink

2019-06-06 Thread Reza Rokni
> >> > Max > >> > > >> > On 29.05.19 03:27, Reza Rokni wrote: > >> > > Hi Flink experts, > >> > > > >> > > I am getting ready to push a PR around a

Re: Timer support in Flink

2019-06-04 Thread Robert Bradshaw
> >> > > I am getting ready to push a PR around a utility >> > class for timeseries join >> > > >> > > left.timestamp match to closest right.timestamp where >> >

Re: Timer support in Flink

2019-06-03 Thread Melissa Pashniak
to push a PR around a utility > > class for timeseries join > > > > > > left.timestamp match to closest right.timestamp where > > right.timestamp <= > > > left.timestamp. >

Re: Timer support in Flink

2019-06-03 Thread Maximilian Michels
nst Flink: In the capability matrix we have "~" for Timer > support in Flink: > > https://beam.apache.org/documentation/runners/capability-matrix/ >

Re: Timer support in Flink

2019-05-30 Thread Reza Rokni
;>>> Cheers, >>>> Max >>>> >>>> On 29.05.19 03:27, Reza Rokni wrote: >>>> > Hi Flink experts, >>>> > >>>> > I am getting ready to push a PR around a utility class for >>>> timeseries join >>>&g

Re: Timer support in Flink

2019-05-30 Thread Alex Van Boxel
> > >>> > left.timestamp match to closest right.timestamp where right.timestamp >>> <= >>> > left.timestamp. >>> > >>> > It makes very heavy use of Event.Time timers and has to do some manual >>> > DoFn cache wo

Re: Timer support in Flink

2019-05-30 Thread Reza Rokni
; > left.timestamp match to closest right.timestamp where right.timestamp >> <= >> > left.timestamp. >> > >> > It makes very heavy use of Event.Time timers and has to do some manual >> > DoFn cache work to get around some O(heavy) issues. Wanted to test &

Re: Timer support in Flink

2019-05-29 Thread Reza Rokni
estamp. > > > > It makes very heavy use of Event.Time timers and has to do some manual > > DoFn cache work to get around some O(heavy) issues. Wanted to test > > things against Flink: In the capability matrix we have "~" for Timer > > support in Flink:

Re: Timer support in Flink

2019-05-29 Thread Maximilian Michels
"~" for Timer support in Flink: https://beam.apache.org/documentation/runners/capability-matrix/ Is that page outdated, if not what are the areas that still need to be addressed please? Cheers Reza -- This email may be confidential and privileged. If you received this communication b

Timer support in Flink

2019-05-28 Thread Reza Rokni
avy) issues. Wanted to test things against Flink: In the capability matrix we have "~" for Timer support in Flink: https://beam.apache.org/documentation/runners/capability-matrix/ Is that page outdated, if not what are the areas that still need to be addressed please? Cheers Reza --