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 D4FF1114F6 for ; Tue, 26 Aug 2014 07:20:13 +0000 (UTC) Received: (qmail 35661 invoked by uid 500); 26 Aug 2014 07:20:13 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 35603 invoked by uid 500); 26 Aug 2014 07:20:13 -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 35593 invoked by uid 99); 26 Aug 2014 07:20:13 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 26 Aug 2014 07:20:13 +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 sebastiano.dipaola@gmail.com designates 209.85.192.48 as permitted sender) Received: from [209.85.192.48] (HELO mail-qg0-f48.google.com) (209.85.192.48) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 26 Aug 2014 07:19:46 +0000 Received: by mail-qg0-f48.google.com with SMTP id i50so13952739qgf.7 for ; Tue, 26 Aug 2014 00:19:45 -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=gasRUHPrr/7QXntJrgG8SkABZkxCSGNDekqi8whGeSA=; b=MDmAuks8jCag10Ah5vTsXq3t694BLvzhkJquYbDsk5mi1AY3iSb6h6/00Hugc74Z7Z bsNWtJM6Q9YGPDCI5TzEpaz8ALb823NdGG2m+O2hw6NszQHW615Du8v+yY7SZSNE7pot 4KMGvQBPEQj9qQVsQ5cM0G+MZ/gwBEOdfcTpb72gVbgcAfIQrcuzk4Jv7+1R8TYq5BM9 FppqR56DBfx7FVzXIXD/c6iD8jCXLV2a1uhN6ifHUVuJQPTkIonKChW54kFswe6Ap8Ae MFrhtkPmOwflKan0sECxiAZ9vPaYfo2rRuiaAFHQeHqRa6RCAi6CxL6o3s1hTFgbVYix nPLg== MIME-Version: 1.0 X-Received: by 10.224.160.83 with SMTP id m19mr43327391qax.95.1409037585250; Tue, 26 Aug 2014 00:19:45 -0700 (PDT) Received: by 10.96.133.130 with HTTP; Tue, 26 Aug 2014 00:19:45 -0700 (PDT) In-Reply-To: <53FBA9ED.6010507@cloudera.com> References: <53FBA9ED.6010507@cloudera.com> Date: Tue, 26 Aug 2014 09:19:45 +0200 Message-ID: Subject: Re: Flume Avro Source and Avro C api From: Sebastiano Di Paola To: user@flume.apache.org Content-Type: multipart/alternative; boundary=047d7bacb2aabe84920501832078 X-Virus-Checked: Checked by ClamAV on apache.org --047d7bacb2aabe84920501832078 Content-Type: text/plain; charset=UTF-8 Hi, As I'm still planning how to do to transport my data, I can use Thrift as well, but how does Thrift and Avro integrates? Avro seems very interesting to serialize data and also pretty straightforward (define a schema -> transform data -> read data again using the same schema). It's not clear to me the role of Thrift (ok it will generate code to make the RPC call) and the integration with Avro. Can you please add more details? Regards. Seba On Mon, Aug 25, 2014 at 11:26 PM, Hari Shreedharan < hshreedharan@cloudera.com> wrote: > Can you use thrift? That is the recommended mechanism for non-java > applications to Flume > > Sebastiano Di Paola wrote: > > > Hi there, > I'm trying to write a small pice of code using Avro C api and then use > a Flume avro sink to write the collected and serialized data to hadoop > HDFS. > > I would like to use Avro C api as all the other lib/code I'm using to > generate/collect my data is in c language and it's already written. So > I'm adding Avro output to an already existing software. > > As I'm reading from avro C API does not support RPC call yet. > > So Is there a way to seamless integrate a Flume avro source with avro > C api? > Is there any already written example? > > Or I have to create my avro file with avro C api (i.e. > my_data_file.avro) on the file system > and then use the already provided avro client > bin/flume-ng avro-client -H localhost -p 41414 -F my_data_file.avro > in order to have the file "read" through the Flume avro source and > sent to the Flume sink on hdfs? > > Isn't it possible only to configure the Flume Avro source to listen on > a particulary port and then use Avro C api to send the message? > > (I did a quick search on avro C api, but i couln't find any function I > could call to answer my previous question) > > Kind regard. > Seba > > --047d7bacb2aabe84920501832078 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,
As I'm still planning how to do to trans= port my data, I can use Thrift as well, but how does Thrift and Avro integr= ates?
Avro seems very interesting to serialize data and also pretty str= aightforward (define a schema -> transform data -> read data again us= ing the same schema).
It's not clear to me the role of Thrift (ok it will generate code = to make the RPC call) and the integration with Avro.
Can you = please add more details?
Regards.
Seba


On Mon, Aug 25, 2014 at 11:26 PM, Hari S= hreedharan <hshreedharan@cloudera.com> wrote:
Can you use thrift? That is the recommended mechanism for non-java app= lications to Flume

Sebastiano Di Paola wrote:

Hi there,
I'm trying to write a small pice of code using Avro C api and then use =
a Flume avro sink to write the collected and serialized data to hadoop
HDFS.

I would like to use Avro C api as all the other lib/code I'm using to <= br> generate/collect my data is in c language and it's already written. So =
I'm adding Avro output to an already existing software.

As I'm reading from avro C API does not support RPC call yet.

So Is there a way to seamless integrate a Flume avro source with avro
C api?
Is there any already written example?

Or I have to create my avro file with avro C api (i.e.
my_data_file.avro) on the file system
and then use the already provided avro client
bin/flume-ng avro-client -H localhost -p 41414 -F my_data_file.avro
in order to have the file "read" through the Flume avro source an= d
sent to the Flume sink on hdfs?

Isn't it possible only to configure the Flume Avro source to listen on =
a particulary port and then use Avro C api to send the message?

(I did a quick search on avro C api, but i couln't find any function I =
could call to answer my previous question)

Kind regard.
Seba

--047d7bacb2aabe84920501832078--