Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8E73017BA1 for ; Wed, 1 Apr 2015 08:07:00 +0000 (UTC) Received: (qmail 62908 invoked by uid 500); 1 Apr 2015 08:07:00 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 62850 invoked by uid 500); 1 Apr 2015 08:07:00 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 62838 invoked by uid 99); 1 Apr 2015 08:07:00 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 01 Apr 2015 08:07:00 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of ewenstephan@gmail.com designates 209.85.213.176 as permitted sender) Received: from [209.85.213.176] (HELO mail-ig0-f176.google.com) (209.85.213.176) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 01 Apr 2015 08:06:34 +0000 Received: by igcxg11 with SMTP id xg11so39447344igc.0 for ; Wed, 01 Apr 2015 01:05:47 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:in-reply-to:references:date:message-id:subject :from:to:content-type; bh=gMXIAuERHvsF8OnFbsQTUBEYS4Hcs6tboInVnlxDEXQ=; b=nIYhtfqIMKg7eXeG6/x/4Cl8W9W0T1Mu8li0ufVJF+h/0PhCfR38L+VS/ELdYaayfc 6xgqZrm273aOyjYn0Blm1ZoXEODMWR3C6GKuoe0QZ6WKRcojIIX7SGNKlVv4upE5WoFP RbaWg7+d1g2Tvb6FHaAowxp2ZNAETzfxy2JGUsSHoty7y0QUmAQqbTJDhfhitvppd/0s ro/cwPNn56FtSh57YUXvkoNHERvlCVhf1LGEzW4v8cBf2xVJUIiMi739P/gwNiWuiCtB bnO7/ygp6+s5EW2YVilkkw08ynyG5gJzMpdcAImVQMH6Fw6Rn8MDw8ReSKSCV8oCAPn5 MvYg== MIME-Version: 1.0 X-Received: by 10.50.66.37 with SMTP id c5mr10222124igt.26.1427875547194; Wed, 01 Apr 2015 01:05:47 -0700 (PDT) Sender: ewenstephan@gmail.com Received: by 10.64.76.130 with HTTP; Wed, 1 Apr 2015 01:05:47 -0700 (PDT) In-Reply-To: References: <551ba188.4a53b40a.4bac.ffff9cd6@mx.google.com> Date: Wed, 1 Apr 2015 10:05:47 +0200 X-Google-Sender-Auth: EbHsCEZM3he0WAZXbcbWA-miipI Message-ID: Subject: Re: A small Project I've been working on From: Stephan Ewen To: "dev@flink.apache.org" Content-Type: multipart/alternative; boundary=001a11339994c64dd20512a52e6e X-Virus-Checked: Checked by ClamAV on apache.org --001a11339994c64dd20512a52e6e Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable It April, 1st, right? On Wed, Apr 1, 2015 at 9:47 AM, Gyula F=C3=B3ra wrote: > Amazing! :) > > On Wed, Apr 1, 2015 at 9:41 AM, wrote: > > > My ruby skills are a bit rust(y) but I=E2=80=99d love to contribute. > > > > > > Can you point me to a repository that I can fork? > > > > > > > > > > > > > > From: Till Rohrmann > > Sent: =E2=80=8EWednesday=E2=80=8E, =E2=80=8E1=E2=80=8E. =E2=80=8EApril= =E2=80=8E, =E2=80=8E2015 =E2=80=8E09=E2=80=8E:=E2=80=8E29 > > To: dev@flink.apache.org > > > > > > > > > > > > Where can I start contributing. I've got the feeling that it will be > > inherently faster than everything else which is out there. > > On Apr 1, 2015 9:18 AM, "Ufuk Celebi" wrote: > > > > > Little side projects ftw. Very nice :-) > > > > > > Can you give some points on how this works internally? Is it making u= se > > of > > > anything generic from the Python API pull request? > > > > > > On Wednesday, April 1, 2015, M=C3=A1rton Balassi > > > wrote: > > > > > > > Woot! > > > > > > > > On Wed, Apr 1, 2015 at 9:01 AM, Aljoscha Krettek < > aljoscha@apache.org > > > > > > > > > wrote: > > > > > > > > > Right now, runtime is roughly thrice that of equivalent java > > programs. > > > > > But I plan on bringing that to the same ballpark using code > > > > > generation. > > > > > > > > > > On Wed, Apr 1, 2015 at 8:54 AM, Fabian Hueske > > > > wrote: > > > > > > :-D > > > > > > This is awesome! > > > > > > > > > > > > Do you have some performance numbers? > > > > > > On Apr 1, 2015 8:43 AM, "Aljoscha Krettek" > > > > wrote: > > > > > > > > > > > >> Hi, > > > > > >> I've been working on a little side project in my free time: Ru= by > > on > > > > > >> Flink (RoF). This should finally allow us to tap into the whol= e > > web > > > > > >> developer ruby world. The design is also flexible enough to > easily > > > > > >> port this to node.js. > > > > > >> > > > > > >> The code is not yet in shape to be made public but this is a > small > > > > > >> preview of what the API looks like: > > > > > >> > > > > > >> input =3D env.read_text_file("/some/path") > > > > > >> > > > > > >> words =3D input.flatMap do |line| > > > > > >> parts =3D line.split(/\W+/) > > > > > >> parts.each do |word| > > > > > >> word, 1 > > > > > >> end > > > > > >> end > > > > > >> > > > > > >> counts =3D words.reduce do |left, right| > > > > > >> left(1), left(1) + right(2) > > > > > >> end > > > > > >> > > > > > >> counts.print() > > > > > >> > > > > > >> env.execute!() > > > > > >> > > > > > >> Cheers, > > > > > >> Aljoscha > > > > > >> > > > > > > > > > > > > > > > --001a11339994c64dd20512a52e6e--