Re: Watermark generation in Windowed Operators

2016-09-17 Thread Chinmay Kolhatkar
Thanks for the information guys. David, I can take a look at heuristic watermark if I get any free cycles. Shunxin, does the Join operator that you're implementing support theta join or is it subset of the theta join? Thanks, Chinmay. On Sat, Sep 17, 2016 at 1:21 AM, David Yan wrote: > Hi S

Re: Watermark generation in Windowed Operators

2016-09-17 Thread Shunxin Lu
Hi Chinmay, The Join Operator should be able to support any user defined join operation. You just need to create a subclass implementing the JoinAccumulation interface and define the behavior you want, then set the accumulation after creating a Join operator instance . Please take a look at the Co