On 22 Sep 2014, at 19:08, Stephan Ewen <[email protected]> wrote: > I'll take "cross". Need it for tests... > > On Mon, Sep 22, 2014 at 5:48 PM, Stephan Ewen <[email protected]> wrote: > >> Hi! >> >> I added a new branch (collections2) that includes the commit moving the >> typeutils to "flink-core" and including the code for the runtime context. >> >> Those who need any of that, please rebase your branch... >> >> Stephan >> >> >> On Mon, Sep 22, 2014 at 4:33 PM, Aljoscha Krettek <[email protected]> >> wrote: >> >>> I'll do groupReduce >>> >>> On Mon, Sep 22, 2014 at 4:13 PM, Till Rohrmann <[email protected]> >>> wrote: >>>> Then I'll take the join operation. >>>> >>>> On Mon, Sep 22, 2014 at 3:44 PM, Ufuk Celebi <[email protected]> wrote: >>>> >>>>> >>>>> On 22 Sep 2014, at 15:37, Stephan Ewen <[email protected]> wrote: >>>>> >>>>>> Hi everyone! >>>>>> >>>>>> I have started with a patch that introduces *"local collection-based >>>>>> execution"* of Flink programs. >>>>> >>>>> Very nice! >>>>> >>>>> To have a list of missing operators: >>>>> >>>>> - flatMap <= I'll take this >>>>> - filter <= I'll take this >>>>> - reduce <= I'll take this >>>>> - groupreduce >>>>> - cogroup >>>>> - join >>>>>
Aljoscha did the reduce. I will do CoGroup.
