Review Board 1.7.22


customizable avro flume interchange - DefaultAvroSource/DefaultAvroSink added

Review Request #3359 - Created Jan. 4, 2012 and updated

Karthik K
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728
FLUME-918
Reviewers
Flume
Flume
AvroSource / AvroSink concrete classes has injectible eventHandlers (SourceEventHandler and SinkEventHandler), to allow for diffrerent avro protocols to be sent over flume NG.  ( not restricted to AvroSourceProtocol , as it stands today). 

Default implementation refers to AvroSourceProtocol still though.

 
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/event/SinkEventHandler.java
New File

    
   
1
package org.apache.flume.event;

    
   
2

   

    
   
3
import java.util.List;

    
   
4

   

    
   
5
import org.apache.avro.AvroRemoteException;

    
   
6
import org.apache.flume.Event;

    
   
7

   

    
   
8
public interface SinkEventHandler {

    
   
9

   

    
   
10
    void unmarshallFlumeEvents(Object protocolObj, List<Event> batchEvents) throws AvroRemoteException;

    
   
11
}
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/event/SourceEventHandler.java
New File
 
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java
Revision 1226957 New Change
 
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
Revision 1226957 New Change
 
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSourceProtocolSinkHandler.java
New File
 
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java
Revision 1226957 New Change
 
http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSourceProtocolImpl.java
New File
 
  1. http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/event/SinkEventHandler.java: Loading...
  2. http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/event/SourceEventHandler.java: Loading...
  3. http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java: Loading...
  4. http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java: Loading...
  5. http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSourceProtocolSinkHandler.java: Loading...
  6. http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java: Loading...
  7. http://svn.apache.org/repos/asf/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSourceProtocolImpl.java: Loading...