Also, regarding the difficulties you mentioned about a new subclass inheriting AbstractWindowedOperator, what specifically are they?
David On Tue, Aug 16, 2016 at 12:31 PM, David Yan <[email protected]> wrote: > Hi Shunxin, > > One problem with join support using WindowedOperator is that Apex operator > does not support variable number of ports so we might have to limit the > join operator to, say, 5 input ports. Implementing join support for > WindowedOperator should not be difficult, but might be a little messy > because we will need to have a watermark control port for each regular > input port, making it 10 total input ports if we support a maximum of 5 > join inputs. > > Please take a look at the JoinAccumulation template interface. That was > there for the future join support I planned to add. > > Also, pay a bit of attention on how you process watermarks from each > input, and let me know if you need help. > > David > > On Fri, Aug 12, 2016 at 11:03 AM, Shunxin Lu <[email protected]> wrote: > >> Hello there, >> >> I am planning to add join support in Windowed Operator, but need some >> advice on how to start. >> Currently I am thinking to add a new subclass inheriting >> AbstractWindowedOperator and do all the work we need in that class (add >> more input ports, do join accumulation, etc.), but I am experiencing some >> difficulties doing so. Or should I directly change the codes in >> AbstractWindowedOperator? >> >> Thanks, >> Shunxin >> > >
