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