Review Board 1.7.22


FLUME-2048 Avro container file deserializer

Review Request #11342 - Created May 23, 2013 and updated

Mike Percy
Reviewers
Flume
flume-git
Spooling directory source deserializer for Avro container files.
Included a unit test
pom.xml
Revision 251f345 New Change
[20] 777 lines
[+20]
778
        <artifactId>hadoop-common</artifactId>
778
        <artifactId>hadoop-common</artifactId>
779
        <version>${hadoop.version}</version>
779
        <version>${hadoop.version}</version>
780
      </dependency>
780
      </dependency>
781

    
   
781

   
782
      <dependency>
782
      <dependency>

    
   
783
        <groupId>commons-codec</groupId>

    
   
784
        <artifactId>commons-codec</artifactId>

    
   
785
        <version>1.8</version>

    
   
786
      </dependency>

    
   
787

   

    
   
788
      <dependency>
783
        <groupId>commons-io</groupId>
789
        <groupId>commons-io</groupId>
784
        <artifactId>commons-io</artifactId>
790
        <artifactId>commons-io</artifactId>
785
        <version>2.1</version>
791
        <version>2.1</version>
786
      </dependency>
792
      </dependency>
787

    
   
793

   
[+20] [20] 302 lines
flume-ng-core/pom.xml
Revision e37de5b New Change
 
flume-ng-core/src/main/java/org/apache/flume/serialization/AvroEventDeserializer.java
New File
 
flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializerType.java
Revision 02abc80 New Change
 
flume-ng-core/src/main/java/org/apache/flume/serialization/LengthMeasurable.java
New File
 
flume-ng-core/src/main/java/org/apache/flume/serialization/RemoteMarkable.java
New File
 
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java
Revision 49521ab New Change
 
flume-ng-core/src/test/java/org/apache/flume/serialization/TestAvroEventDeserializer.java
New File
 
flume-ng-core/src/test/java/org/apache/flume/serialization/TransientPositionTracker.java
New File
 
flume-ng-doc/sphinx/FlumeUserGuide.rst
Revision a8f84e5 New Change
 
  1. pom.xml: Loading...
  2. flume-ng-core/pom.xml: Loading...
  3. flume-ng-core/src/main/java/org/apache/flume/serialization/AvroEventDeserializer.java: Loading...
  4. flume-ng-core/src/main/java/org/apache/flume/serialization/EventDeserializerType.java: Loading...
  5. flume-ng-core/src/main/java/org/apache/flume/serialization/LengthMeasurable.java: Loading...
  6. flume-ng-core/src/main/java/org/apache/flume/serialization/RemoteMarkable.java: Loading...
  7. flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java: Loading...
  8. flume-ng-core/src/test/java/org/apache/flume/serialization/TestAvroEventDeserializer.java: Loading...
  9. flume-ng-core/src/test/java/org/apache/flume/serialization/TransientPositionTracker.java: Loading...
  10. flume-ng-doc/sphinx/FlumeUserGuide.rst: Loading...