Review Board 1.7.22


FLUME-1898. Thrift Source

Review Request #9352 - Created Feb. 7, 2013 and submitted

Hari Shreedharan
FLUME-1898
Reviewers
Flume
flume-git
Thrift Source.
Added several unit tests.
flume-ng-configuration/src/main/java/org/apache/flume/conf/source/SourceConfiguration.java
Revision 3312b04 New Change
[20] 190 lines
[+20] [+] private ChannelSelectorType getKnownChannelSelector(String type) {
191
    /**
191
    /**
192
     * HTTP Source
192
     * HTTP Source
193
     *
193
     *
194
     * @see org.apache.flume.source.http.HTTPSource
194
     * @see org.apache.flume.source.http.HTTPSource
195
     */
195
     */
196
    HTTP("org.apache.flume.source.http.HTTPSourceConfiguration");
196
    HTTP("org.apache.flume.source.http.HTTPSourceConfiguration"),

    
   
197

   

    
   
198
    /**

    
   
199
     * HTTP Source

    
   
200
     *

    
   
201
     * @see org.apache.flume.source.ThriftSource

    
   
202
     */

    
   
203
    THRIFT("org.apache.flume.source.http.ThriftSourceConfiguration");
197

    
   
204

   
198
    private String srcConfigurationName;
205
    private String srcConfigurationName;
199

    
   
206

   
200
    private SourceConfigurationType(String src) {
207
    private SourceConfigurationType(String src) {
201
      this.srcConfigurationName = src;
208
      this.srcConfigurationName = src;
[+20] [20] 39 lines
flume-ng-configuration/src/main/java/org/apache/flume/conf/source/SourceType.java
Revision 058ca1c New Change
 
flume-ng-core/pom.xml
Revision 7db4f23 New Change
 
flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java
New File
 
flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java
New File
 
  1. flume-ng-configuration/src/main/java/org/apache/flume/conf/source/SourceConfiguration.java: Loading...
  2. flume-ng-configuration/src/main/java/org/apache/flume/conf/source/SourceType.java: Loading...
  3. flume-ng-core/pom.xml: Loading...
  4. flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java: Loading...
  5. flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java: Loading...