What do you think of changing the TestBase such that all new test programs are not only executed with the LocalExecutor, but also with the Collection execution environment? Would give us massive coverage for the collection execution for free...
On Mon, Sep 22, 2014 at 11:09 PM, Stephan Ewen <[email protected]> wrote: > Will do mapPartition... > > On Mon, Sep 22, 2014 at 7:34 PM, Ufuk Celebi <[email protected]> wrote: > >> >> 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. >> > >
