Return-Path: X-Original-To: apmail-flume-user-archive@www.apache.org Delivered-To: apmail-flume-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CF6DCD18C for ; Wed, 3 Oct 2012 10:43:18 +0000 (UTC) Received: (qmail 73880 invoked by uid 500); 3 Oct 2012 10:43:18 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 73777 invoked by uid 500); 3 Oct 2012 10:43:17 -0000 Mailing-List: contact user-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flume.apache.org Delivered-To: mailing list user@flume.apache.org Received: (qmail 73757 invoked by uid 99); 3 Oct 2012 10:43:17 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Oct 2012 10:43:17 +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 deepak8.kumar@citi.com designates 67.231.145.106 as permitted sender) Received: from [67.231.145.106] (HELO mx0a-00123c01.pphosted.com) (67.231.145.106) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Oct 2012 10:43:07 +0000 Received: from pps.filterd (m0008095 [127.0.0.1]) by mx0a-00123c02.pphosted.com (8.14.5/8.14.5) with SMTP id q93AfaAf025649; Wed, 3 Oct 2012 10:42:44 GMT Received: from mail.citigroup.com ([192.193.222.7]) by mx0a-00123c02.pphosted.com with ESMTP id 17cmtjnud2-1 (version=TLSv1/SSLv3 cipher=AES256-SHA bits=256 verify=NOT); Wed, 03 Oct 2012 10:42:44 +0000 Received: from imbhub-mw03.nam.nsroot.net (namdlpdimpgt05.nam.nsroot.net [169.193.226.14]) by smtpinbound.citigroup.com (Switch-3.4.1/Switch-3.4.1) with ESMTP id q93AdNCM021256; Wed, 3 Oct 2012 10:39:23 GMT Received: from exnjiht02.nam.nsroot.net (EXNJIHT02.nam.nsroot.net [150.110.165.228]) by imbhub-mw03.nam.nsroot.net (Switch-3.4.1/Switch-3.4.1) with ESMTP id q93AgfW9027218; Wed, 3 Oct 2012 10:42:42 GMT Received: from exnjaht03.nam.nsroot.net (150.110.107.30) by exnjiht02.nam.nsroot.net (150.110.165.228) with Microsoft SMTP Server (TLS) id 8.3.264.0; Wed, 3 Oct 2012 06:42:41 -0400 Received: from extxht04.nam.nsroot.net (165.203.255.113) by exnjaht03.nam.nsroot.net (150.110.107.30) with Microsoft SMTP Server (TLS) id 8.3.264.0; Wed, 3 Oct 2012 06:42:40 -0400 Received: from extxmb35.nam.nsroot.net ([165.203.255.105]) by extxht04.nam.nsroot.net ([165.203.255.113]) with mapi; Wed, 3 Oct 2012 05:42:40 -0500 From: "Kumar, Deepak8 " To: "'user@flume.apache.org'" CC: "'shumin.wu@gmail.com'" Date: Wed, 3 Oct 2012 05:42:38 -0500 Subject: RE: Moving from Flume OG to Flume NG Thread-Topic: Moving from Flume OG to Flume NG Thread-Index: Ac2VyPdh7OCnWM9GRAKapqab6E1A/wLih+bw Message-ID: References: In-Reply-To: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: acceptlanguage: en-US Content-Type: multipart/alternative; boundary="_000_E21A63346444A54D9EE43438350412B507400D1743extxmb35namns_" MIME-Version: 1.0 X-WiganSS: 01000000010018exnjaht03.nam.nsroot.net ID0044 X-CFilter-Loop: Reflected X-Proofpoint-Virus-Version: vendor=fsecure engine=2.50.10432:5.7.7855,1.0.431,0.0.0000 definitions=2012-10-03_01:2012-10-03,2012-10-02,1970-01-01 signatures=0 --_000_E21A63346444A54D9EE43438350412B507400D1743extxmb35namns_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Hi Shumin, I have gone through the documentation, but it don't have much. Do you have = any use case in which you are using CustomSource? As in flume 0.9.4, we do = have flume master url where we can see the source/sinks/decorators etc. How= we can verify here whether our custom source is fine & up or have any erro= rs? It would be much help if you please guide me a bit. Regards, Deepak From: Shumin Wu [mailto:shumin.wu@gmail.com] Sent: Tuesday, September 18, 2012 2:11 PM To: user@flume.apache.org Subject: Re: Moving from Flume OG to Flume NG Hi Deepark, I had hard time switching from OG to NG in the beginning, too. The new way = in NG to make your custom source would look like this: public class CustomSource extends AbstractSource implements PollableSource,= Configurable or public class CustomSource extends AbstractSource implements EventDrivenSour= ce, Configurable , depending on your source type. Brock's link is a good reading resource. Shumin On Tue, Sep 18, 2012 at 11:05 AM, Brock Noland > wrote: Hi, The flume developer guide as these details: http://flume.apache.org/FlumeDeveloperGuide.html Brock On Tue, Sep 18, 2012 at 1:02 PM, Kumar, Deepak8 > wrote: > Hi, > I am trying to switch from Flume 0.94 to Flume NG. In previous version we= do have the static class EventSource.Base through which we can create our = own Source or Sink. I don't find anything as such here in flume NG. > > Could you please guide me how do we create our own Sources here in Flume = NG? > > Regards, > Deepak -- Apache MRUnit - Unit testing MapReduce - http://incubator.apache.org/mrunit= / --_000_E21A63346444A54D9EE43438350412B507400D1743extxmb35namns_ Content-Type: text/html; charset="us-ascii" Content-Transfer-Encoding: quoted-printable

Hi Shumin= ,

I have gone through the = documentation, but it don’t have much. Do you have any use case in wh= ich you are using CustomSource? As in flume 0.9.4, we do have flume master = url where we can see the source/sinks/decorators etc. How we can verify her= e whether our custom source is fine & up or have any errors?=

 

It would be much help if you please guide me a bit.

 

<= p class=3DMsoNormal>Regards,

Deepak

&nbs= p;

From: Shumin Wu [mailto:shum= in.wu@gmail.com]
Sent: Tuesday, September 18, 2012 2:11 PM
To: user@flume.apache.org
Subject: Re: Moving from Flume OG = to Flume NG

 

Hi Deepark,
I had hard time switching from OG to NG in the beginning, too. The new wa= y in NG to make your custom source would look like this:

public clas= s CustomSource extends AbstractSource implements PollableSource, Configurab= le

or

public class CustomSource extends AbstractSource imple= ments EventDrivenSource, Configurable

, depending on your source typ= e.

Brock's link is a good reading resource.

Shumin=

On Tue, Sep 18, 2012 at 11:05 AM, Brock Nolan= d <brock@clouder= a.com> wrote:

Hi,

The flum= e developer guide as these details:

http://flume.apache.org/Flum= eDeveloperGuide.html

Brock


On Tue, Sep 18, 2012 at 1:02 PM,= Kumar, Deepak8 <deepak8.kumar= @citi.com> wrote:
> Hi,
> I am trying to switch from Flu= me 0.94 to Flume NG. In previous version we do have the static class EventS= ource.Base through which we can create our own Source or Sink. I don't find= anything as such here in flume NG.
>
> Could you please guide = me how do we create our own Sources here in Flume NG?
>
> Regar= ds,
> Deepak


--
Apache MRUnit - Unit test= ing MapReduce - http://incubator.apache.org/mrunit/

=

 

= --_000_E21A63346444A54D9EE43438350412B507400D1743extxmb35namns_--