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
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