Return-Path: X-Original-To: apmail-hadoop-user-archive@minotaur.apache.org Delivered-To: apmail-hadoop-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8394D10F4B for ; Mon, 12 May 2014 10:50:54 +0000 (UTC) Received: (qmail 804 invoked by uid 500); 10 May 2014 23:26:40 -0000 Delivered-To: apmail-hadoop-user-archive@hadoop.apache.org Received: (qmail 40552 invoked by uid 500); 10 May 2014 23:14:28 -0000 Mailing-List: contact user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@hadoop.apache.org Delivered-To: mailing list user@hadoop.apache.org Received: (qmail 26748 invoked by uid 99); 10 May 2014 22:58:08 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 10 May 2014 22:58:08 +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 smarty.juice@gmail.com designates 209.85.219.44 as permitted sender) Received: from [209.85.219.44] (HELO mail-oa0-f44.google.com) (209.85.219.44) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 09 May 2014 01:25:29 +0000 Received: by mail-oa0-f44.google.com with SMTP id i11so4124763oag.3 for ; Thu, 08 May 2014 18:25:09 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=OzQ18mSEFIGu+gwJzNAsKJB9dLNv8AlyOYfCkRwMx7c=; b=jff6yoVAlVJ5H2Z5pmUn10XHfJI69m0DVzjz4cRV55ONdK6DRlziV+uDsosXXy2y3G L2m0GwFsDvZsF8fovoIUhf41Fq5EaNNBIbeG6QB/x4ty0xgx1nrjpqnmQXNt5aJYiZLb MRnmGNGaQ+gYCDlgVrkH7khYnZ+n0+Sv1VvknkvBuwGI5WXmQ7cgoGz5oyKRt4SujihL 9IHqx1lHhywCP+cbUofbQshrYKnQfH0NZFr7pEQKYsf8xxHZojPQ1IWT7qWrGlzygswx oQGqJ8TvUVZeAfCYIPv99ssOBBG0Ph6nLB0r3yEB6ceFONtesJrmVCknvx/+Eu9/RIUZ Ci4w== MIME-Version: 1.0 X-Received: by 10.60.140.201 with SMTP id ri9mr8326161oeb.74.1399598709012; Thu, 08 May 2014 18:25:09 -0700 (PDT) Received: by 10.182.74.10 with HTTP; Thu, 8 May 2014 18:25:08 -0700 (PDT) In-Reply-To: References: <11564200.Tc0LUDiuXJ@f6-dat6-306-27> Date: Thu, 8 May 2014 21:25:08 -0400 Message-ID: Subject: Re: Realtime sensor's tcpip data to hadoop From: Hardik Pandya To: user@hadoop.apache.org Content-Type: multipart/alternative; boundary=047d7b4727dce0fd5e04f8ed77dd X-Virus-Checked: Checked by ClamAV on apache.org --047d7b4727dce0fd5e04f8ed77dd Content-Type: text/plain; charset=UTF-8 If I were you I would ask following questions to get the answer > forget about for a minute and ask yourself how tcpip data are currently being stored - in fs/rdbmbs? > hadoop is for offiline batch processing - if you are looking for real time streaming solution - there is a storm (from linkedin) that can go well with kafka (messaging queue) or spark streaming (which is in memory map-reduce) and takes real time streams - has in built twitter api but you need to write your own service to poll data every few seconds and send it in RDD format > storm is complementary to hadoop - spark in conjuction with hadoop will allow you to do both offline and real time data analytics On Tue, May 6, 2014 at 10:48 PM, Alex Lee wrote: > Sensors' may send tcpip data to server. Each sensor may send tcpip data > like a stream to the server, the quatity of the sensors and the data rate > of the data is high. > > Firstly, how the data from tcpip can be put into hadoop. It need to do > some process and store in hbase. Does it need through save to data files > and put into hadoop or can be done in some direct ways from tcpip. Is there > any software module can take care of this. Searched that Ganglia Nagios and > Flume may do it. But when looking into details, ganglia and nagios are > more for monitoring hadoop cluster itself. Flume is for log files. > > Secondly, if the total network traffic from sensors are over the limit of > one lan port, how to share the loads, is there any component in hadoop to > make this done automatically. > > Any suggestions, thanks. > --047d7b4727dce0fd5e04f8ed77dd Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
If I were you I would ask following questions to get the a= nswer

> forget about for a minute and ask yourself ho= w tcpip data are currently being stored - in fs/rdbmbs?
> hadoop is = for offiline batch processing - if you are looking for real time streaming = solution - there is a storm (from linkedin) that can go well with kafka (me= ssaging queue) or spark streaming (which is in memory map-reduce) and takes= real time streams - has in built twitter api but you need to write your ow= n service to poll data every few seconds and send it in RDD format=C2=A0
> storm is complementary to hadoop - spark in conjuction with= hadoop will allow you to do both offline and real time data analytics




On Tue, May 6, 2014 at 10:48 PM, Alex Lee <eliyart@hotmail.com> wrote:
Sensors'=C2=A0may send tcpip data to server. Each= sensor may send tcpip=C2=A0data like a stream to the server, the quatity o= f the sensors and the data rate of the data is high.
=C2=A0
Firstly, = how the=C2=A0data from tcpip can be put into hadoop. It need to do some pro= cess and store in hbase. Does it need through save to=C2=A0data files and p= ut into hadoop=C2=A0or can be done in some=C2=A0direct ways from tcpip. Is = there any software module can take care of this.=C2=A0Searched that=C2=A0Ga= nglia=C2=A0Nagios and Flume may do it. But when looking into details, gangl= ia and nagios are more=C2=A0for monitoring hadoop cluster itself. Flume is = for log files.
=C2=A0
Secondly, if=C2=A0the=C2=A0total network traffic from sensors are= over the limit of one lan port, how to share the loads, is there any compo= nent in hadoop to make this done automatically.
=C2=A0
Any suggestion= s, thanks.

--047d7b4727dce0fd5e04f8ed77dd--