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