----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/3359/ -----------------------------------------------------------
(Updated 2012-01-04 00:35:14.420595)
Review request for Flume.
Changes
-------
Adding missing 3 new sourcefiles ( DefaultAvroSource/Sink/ChannelEventProcessor)
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/sink/DefaultAvroSink.java
PRE-CREATION
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/main/java/org/apache/flume/source/ChannelEventProcessor.java
PRE-CREATION
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/DefaultAvroSource.java
PRE-CREATION
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
