flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jeff Lord <jl...@cloudera.com>
Subject Re: Avro source and sink
Date Wed, 03 Sep 2014 04:02:08 GMT
Ed,

Did you take a look at the javadoc in the source?
Basically the source uses netty as a server and the sink is just an rpc
client.
If you read over the doc which is in the two links below and take a look at
the developer guide and still have questions just ask away and someone will
help to answer.

https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java

https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java

https://flume.apache.org/FlumeDeveloperGuide.html#transaction-interface

-Jeff






On Tue, Sep 2, 2014 at 6:36 PM, Ed Judge <ejudgie@gmail.com> wrote:

> Does anyone know of any good documentation that talks about the
> protocol/negotiation used between an Avro source and sink?
>
> Thanks,
> Ed
>
>

Mime
View raw message