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 <[email protected]> Sent: Friday, January 16, 2015 3:47 PM To: [email protected] 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 application. Let me know if that meets your needs. -Joey [1] http://flume.apache.org/FlumeDeveloperGuide.html#embedded-agent On Fri, Jan 16, 2015 at 10:30 AM, Carlotta Hicks <[email protected]> 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
