-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/3359/
-----------------------------------------------------------

(Updated 2012-01-04 00:32:26.125490)


Review request for Flume.


Changes
-------

in-place AvroSource::toString() to avoid bogus diff in the diff report. 


Summary
-------

AvroSource / AvroSink made abstract, that are agnostic of the Avro object used 
for transport or the interchange between Avro objects and the Flume 'Event's 
and 'Channel's for communication. 


DefaultAvroSource  / DefaultAvroSink in place to preserve existing behavior. 

Custom Avro transports can inherit from AvroSource / AvroSink-s , to override 
the methods. 


This addresses bug FLUME-918.
    https://issues.apache.org/jira/browse/FLUME-918


Diffs (updated)
-----

  
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
 1226957 
  
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java
 1226957 
  
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestAvroSink.java
 1226957 
  
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java
 1226957 

Diff: https://reviews.apache.org/r/3359/diff


Testing
-------


Thanks,

Karthik

Reply via email to