flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ed Judge <ejud...@gmail.com>
Subject Re: Avro source and sink
Date Wed, 03 Sep 2014 17:00:23 GMT
That’s helpful but isn’t there some type of Avro schema negotiation that occurs?

-Ed

On Sep 3, 2014, at 12:02 AM, Jeff Lord <jlord@cloudera.com> wrote:

> 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