flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Carlotta Hicks <Carlotta.Hi...@sas.com>
Subject RE: Java API for Flume Agent
Date Sat, 17 Jan 2015 04:49:54 GMT
Thanks Joey!  I would love to use the embedded agent.  It is exactly what I am looking for.
 However, I can't use the embedded agent because with the embedded agent, the sink must be
avro.  I need the sink to be hbase.
I am assuming that requirements has not changed.  Please correct me if I am wrong.
From: Joey Echeverria <joey@cloudera.com>
Sent: Friday, January 16, 2015 3:47 PM
To: user@flume.apache.org
Subject: Re: Java API for Flume Agent

You could use an embedded flume agent[1]. This will do the same thing
that the Flume flow does but run flume inside of another Java

Let me know if that meets your needs.


[1] http://flume.apache.org/FlumeDeveloperGuide.html#embedded-agent

On Fri, Jan 16, 2015 at 10:30 AM, Carlotta Hicks <Carlotta.Hicks@sas.com> wrote:
> I need to create an agent using java API to load an HBase table using a CSV
> file.  I am able to accomplish this using flume-ng and an agent with a
> spooldir directory source, file channel and HBase sink.
> I need information on how to accomplish this via a java API.
> Any help would be appreciated.
> -CM

Joey Echeverria

View raw message