Review Board 1.7.22


FLUME-896 Implement file write ahead log channel

Review Request #4325 - Created March 14, 2012 and submitted

Brock Noland
trunk
FLUME-896
Reviewers
Flume
flume-git
Attached patch not meant for commit. Just posting here for easy review.

 
flume-ng-channels/flume-file-channel/pom.xml
Revision 48d1481 New Change
[20] 66 lines
[+20]
67
      <groupId>org.slf4j</groupId>
67
      <groupId>org.slf4j</groupId>
68
      <artifactId>slf4j-log4j12</artifactId>
68
      <artifactId>slf4j-log4j12</artifactId>
69
      <scope>test</scope>
69
      <scope>test</scope>
70
    </dependency>
70
    </dependency>
71

    
   
71

   

    
   
72
    <dependency>

    
   
73
      <groupId>org.apache.hadoop</groupId>

    
   
74
      <artifactId>${hadoop.common.artifact.id}</artifactId>

    
   
75
    </dependency>

    
   
76

   
72
  </dependencies>
77
  </dependencies>
73

    
   
78

   

    
   
79
  <profiles>

    
   
80

   

    
   
81
    <profile>

    
   
82
      <id>hadoop-0.23</id>

    
   
83
      <activation>

    
   
84
        <property>

    
   
85
          <name>hadoop.profile</name>

    
   
86
          <value>23</value>

    
   
87
        </property>

    
   
88
      </activation>

    
   
89
      <dependencies>

    
   
90
        <dependency>

    
   
91
          <groupId>org.apache.hadoop</groupId>

    
   
92
          <artifactId>hadoop-auth</artifactId>

    
   
93
        </dependency>

    
   
94
        <dependency>

    
   
95
          <groupId>org.slf4j</groupId>

    
   
96
          <artifactId>slf4j-jcl</artifactId>

    
   
97
        </dependency>

    
   
98
        <dependency>

    
   
99
          <groupId>commons-logging</groupId>

    
   
100
          <artifactId>commons-logging</artifactId>

    
   
101
        </dependency>

    
   
102
        <dependency>

    
   
103
          <groupId>commons-configuration</groupId>

    
   
104
          <artifactId>commons-configuration</artifactId>

    
   
105
        </dependency>

    
   
106
      </dependencies>

    
   
107
    </profile>

    
   
108

   

    
   
109
  </profiles>

    
   
110

   

    
   
111

   

    
   
112

   
74
</project>
113
</project>
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java
Revision a279453 New Change
 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannelEvent.java
New File
 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/SequenceIDBuffer.java
New File
 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WAL.java
New File
 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WALDataFile.java
New File
 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WALEntry.java
New File
 
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WALReplayResult.java
New File
 
flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannel.java
Revision ab66998 New Change
 
flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/wal/TestSequenceIDBuffer.java
New File
 
flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/wal/TestWAL.java
New File
 
  1. flume-ng-channels/flume-file-channel/pom.xml: Loading...
  2. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java: Loading...
  3. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannelEvent.java: Loading...
  4. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/SequenceIDBuffer.java: Loading...
  5. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WAL.java: Loading...
  6. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WALDataFile.java: Loading...
  7. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WALEntry.java: Loading...
  8. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/wal/WALReplayResult.java: Loading...
  9. flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannel.java: Loading...
  10. flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/wal/TestSequenceIDBuffer.java: Loading...
  11. flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/wal/TestWAL.java: Loading...