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 EFF7910E5B for ; Thu, 27 Nov 2014 14:20:05 +0000 (UTC) Received: (qmail 27804 invoked by uid 500); 27 Nov 2014 14:20:05 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 27740 invoked by uid 500); 27 Nov 2014 14:20:05 -0000 Mailing-List: contact dev-help@flink.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.incubator.apache.org Delivered-To: mailing list dev@flink.incubator.apache.org Received: (qmail 27727 invoked by uid 99); 27 Nov 2014 14:20:05 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Nov 2014 14:20:05 +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 (athena.apache.org: domain of balassi.marton@gmail.com designates 209.85.215.54 as permitted sender) Received: from [209.85.215.54] (HELO mail-la0-f54.google.com) (209.85.215.54) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Nov 2014 14:20:01 +0000 Received: by mail-la0-f54.google.com with SMTP id gf13so4172765lab.41 for ; Thu, 27 Nov 2014 06:19:40 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type; bh=iwTfYV8UJUvY3ny55A5CRm+nIig5+wZntgieUPmILf4=; b=UBHaQ22bOvgkrVaVQqAn2pE+rAIyrUDKN5uVR1A+0gV9DZWRKfytmcDRJdja/WOTzy 5XvJiaV7Em8tDYp2ZHuQ0gKyCnNAVonNvIIBJN/udQsyucvOZzAafXojciUE6GqKvslq CsaGCQrITnHfsnVUN3MLFXAAATXXfur2cGp3pxd1oO5KHNtGw/vyGtEVmgL7SGio4WkV 1ORZr8M26EMQV4ExQ+S4RLSgw7jh4/2lSY2f6fi45XOM4EosGwMmOx9VS6tY9w/hd/dD FQXVpc7cHbUB+70w7PDwBVlCj3O1lFb07ovn5e4uDIt9S3ts1CtMtGmxLTQEPNV2aQ1e zW7g== X-Received: by 10.152.22.135 with SMTP id d7mr39242975laf.46.1417097980166; Thu, 27 Nov 2014 06:19:40 -0800 (PST) MIME-Version: 1.0 Received: by 10.25.85.148 with HTTP; Thu, 27 Nov 2014 06:19:19 -0800 (PST) In-Reply-To: References: From: =?UTF-8?Q?M=C3=A1rton_Balassi?= Date: Thu, 27 Nov 2014 15:19:19 +0100 Message-ID: Subject: Re: Samoa on Flink To: dev@flink.incubator.apache.org Content-Type: multipart/alternative; boundary=089e0158b9c6b847850508d7d51f X-Virus-Checked: Checked by ClamAV on apache.org --089e0158b9c6b847850508d7d51f Content-Type: text/plain; charset=UTF-8 Hey, Thanks Vasia, great idea. When we've started the streaming development the first sketch API we had is was actually really similar to Storm's API a couple of versions back. I've talked to Gyula about the issue when we've first heard about SAMOA ago and we are confident that porting Samoa to Flink streaming shoul be definitely managable and really useful as Paris mentions. Luckily they have ASF2 license so the legal cooperation is clear. The rest is on us and fortunately Paris might have a candidate already to kick off the development. :) Cheers, Marton On Thu, Nov 27, 2014 at 2:05 PM, Paris Carbone wrote: > Hey Vasia, > > I really like the idea and it seems we have some volunteers from our side > already! > It is in my opinion a starter task since it requires to create a simple > adapter for flink as well as mapping abstractions to our streaming topology > API in a similar fashion (in its simplest form just using several flatmaps). > > It will serve as a suitable common layer to make some comparisons between > flink-streaming to storm, s4 and samoa on incremental machine learning > tasks. > > Paris > > > On 27 Nov 2014, at 13:59, Vasiliki Kalavri > wrote: > > > > Hello everyone, > > > > Last week at Strata, I attended a talk about a streaming machine learning > > framework from Yahoo labs, SAMOA: https://github.com/yahoo/samoa. The > > project is going through apache incubation application and currently runs > > on Storm, S4 and Samza. > > > > After the talk, I spoke with the guy that presented it and we both > thought > > that it'd be cool to port Samoa on Flink. > > > > I'm writing about this here because I want to know your thoughts on this > > and also because I'm not very familiar with the Streaming-API, so I will > > need your input :) > > I have already discussed with Paris and there is interest to pick this up > > from some students at KTH as well. > > As far as I understand, Samoa expects an API similar to that of Storm and > > from there the integration should be pretty straight-forward. > > > > So, do you think it would be feasible and -most importantly- worth it? > > > > Cheers, > > Vasia. > > --089e0158b9c6b847850508d7d51f--