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