Review Board 1.7.22


FLUME-1896. Thrift Rpc Client.

Review Request #9284 - Created Feb. 4, 2013 and submitted

Hari Shreedharan
FLUME-1896
Reviewers
Flume
flume-git
Added thrift rpc client. Detailed description posted on jira.
Added unit tests for new code.

Diff revision 8

This is not the most recent revision of the diff. The latest diff is revision 11. See what's changed.

1 2 3 4 5 6 7 8 9 10 11
1 2 3 4 5 6 7 8 9 10 11

  1. pom.xml: Loading...
  2. flume-ng-legacy-sources/flume-thrift-source/pom.xml: Loading...
  3. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/EventStatus.java: Loading...
  4. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/Priority.java: Loading...
  5. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEvent.java: Loading...
  6. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java: Loading...
  7. flume-ng-legacy-sources/flume-thrift-source/src/main/thrift/aslv2: Loading...
  8. flume-ng-sdk/pom.xml: Loading...
  9. flume-ng-sdk/src/main/java/org/apache/flume/api/HostInfo.java: Loading...
  10. flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientConfigurationConstants.java: Loading...
  11. flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientFactory.java: Loading...
  12. flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java: Loading...
  13. flume-ng-sdk/src/main/java/org/apache/flume/thrift/Status.java: Loading...
  14. flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftFlumeEvent.java: Loading...
  15. flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java: Loading...
  16. flume-ng-sdk/src/main/thrift/aslv2: Loading...
  17. flume-ng-sdk/src/main/thrift/flume.thrift: Loading...
  18. flume-ng-sdk/src/test/java/org/apache/flume/api/TestThriftRpcClient.java: Loading...
  19. flume-ng-sdk/src/test/java/org/apache/flume/api/ThriftTestingSource.java: Loading...
  20. flume-ng-sources/flume-scribe-source/pom.xml: Loading...
  21. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/LogEntry.java: Loading...
  22. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ResultCode.java: Loading...
  23. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java: Loading...
  24. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java: Loading...
  25. flume-ng-sources/flume-scribe-source/src/main/thrift/aslv2: Loading...
  26. flume-ng-sources/flume-scribe-source/src/main/thrift/scribe-source.thrift: Loading...
pom.xml
Revision faa67f9 New Change
[20] 137 lines
[+20]
138
        </dependencies>
138
        </dependencies>
139
      </dependencyManagement>
139
      </dependencyManagement>
140
    </profile>
140
    </profile>
141

    
   
141

   
142
    <profile>
142
    <profile>
143
      <id>compileThrift</id>
143
      <id>compileThriftLegacy</id>
144
      <activation>
144
      <activation>
145
        <activeByDefault>false</activeByDefault>
145
        <activeByDefault>false</activeByDefault>
146
      </activation>
146
      </activation>
147
      <properties>
147
      <properties>
148
        <thrift.executable>${env.THRIFT_HOME}/bin/thrift</thrift.executable>
148
        <thrift.executable>${env.THRIFT_HOME}/bin/thrift</thrift.executable>
[+20] [20] 561 lines
[+20]
710
      </dependency>
710
      </dependency>
711

    
   
711

   
712
      <dependency>
712
      <dependency>
713
        <groupId>org.apache.thrift</groupId>
713
        <groupId>org.apache.thrift</groupId>
714
        <artifactId>libthrift</artifactId>
714
        <artifactId>libthrift</artifactId>
715
        <version>0.6.1</version>
715
        <version>0.9.0</version>
716
        <exclusions>
716
        <exclusions>
717
          <exclusion>
717
          <exclusion>
718
            <groupId>javax.servlet</groupId>
718
            <groupId>javax.servlet</groupId>
719
            <artifactId>servlet-api</artifactId>
719
            <artifactId>servlet-api</artifactId>
720
          </exclusion>
720
          </exclusion>
[+20] [20] 229 lines
[+20]
950
        <artifactId>flume-ng-sdk</artifactId>
950
        <artifactId>flume-ng-sdk</artifactId>
951
        <version>1.4.0-SNAPSHOT</version>
951
        <version>1.4.0-SNAPSHOT</version>
952
      </dependency>
952
      </dependency>
953

    
   
953

   
954
      <dependency>
954
      <dependency>

    
   
955
        <groupId>org.apache.flume</groupId>

    
   
956
        <artifactId>flume-ng-sdk</artifactId>

    
   
957
        <version>1.4.0-SNAPSHOT</version>

    
   
958
        <classifier>tests</classifier>

    
   
959
        <scope>test</scope>

    
   
960
      </dependency>

    
   
961

   

    
   
962
      <dependency>
955
        <groupId>org.apache.flume.flume-ng-clients</groupId>
963
        <groupId>org.apache.flume.flume-ng-clients</groupId>
956
        <artifactId>flume-ng-log4jappender</artifactId>
964
        <artifactId>flume-ng-log4jappender</artifactId>
957
        <version>1.4.0-SNAPSHOT</version>
965
        <version>1.4.0-SNAPSHOT</version>
958
      </dependency>
966
      </dependency>
959

    
   
967

   
[+20] [20] 88 lines
flume-ng-legacy-sources/flume-thrift-source/pom.xml
Revision b9667cd New Change
 
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/EventStatus.java
Revision 327107a New Change
 
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/Priority.java
Revision d2495d2 New Change
 
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEvent.java
Revision 2bb6cfd New Change
 
flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
Revision 0f2ad2d New Change
 
flume-ng-legacy-sources/flume-thrift-source/src/main/thrift/aslv2
New File
 
flume-ng-sdk/pom.xml
Revision ab066d5 New Change
 
flume-ng-sdk/src/main/java/org/apache/flume/api/HostInfo.java
Revision 7388a45 New Change
 
flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientConfigurationConstants.java
Revision ab4c3de New Change
 
flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientFactory.java
Revision 3c93921 New Change
 
flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java
New File
 
flume-ng-sdk/src/main/java/org/apache/flume/thrift/Status.java
New File
 
flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftFlumeEvent.java
New File
 
flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java
New File
 
flume-ng-sdk/src/main/thrift/aslv2
New File
 
flume-ng-sdk/src/main/thrift/flume.thrift
New File
 
flume-ng-sdk/src/test/java/org/apache/flume/api/TestThriftRpcClient.java
New File
 
flume-ng-sdk/src/test/java/org/apache/flume/api/ThriftTestingSource.java
New File
 
flume-ng-sources/flume-scribe-source/pom.xml
Revision 588207d New Change
 
flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/LogEntry.java
Revision 401a7e4 New Change
 
flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ResultCode.java
Revision 6bfa84c New Change
 
flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java
Revision ccde51b New Change
 
flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java
Revision 6190b11 New Change
 
flume-ng-sources/flume-scribe-source/src/main/thrift/aslv2
New File
 
flume-ng-sources/flume-scribe-source/src/main/thrift/scribe-source.thrift
New File
 
  1. pom.xml: Loading...
  2. flume-ng-legacy-sources/flume-thrift-source/pom.xml: Loading...
  3. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/EventStatus.java: Loading...
  4. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/Priority.java: Loading...
  5. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEvent.java: Loading...
  6. flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java: Loading...
  7. flume-ng-legacy-sources/flume-thrift-source/src/main/thrift/aslv2: Loading...
  8. flume-ng-sdk/pom.xml: Loading...
  9. flume-ng-sdk/src/main/java/org/apache/flume/api/HostInfo.java: Loading...
  10. flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientConfigurationConstants.java: Loading...
  11. flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientFactory.java: Loading...
  12. flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java: Loading...
  13. flume-ng-sdk/src/main/java/org/apache/flume/thrift/Status.java: Loading...
  14. flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftFlumeEvent.java: Loading...
  15. flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java: Loading...
  16. flume-ng-sdk/src/main/thrift/aslv2: Loading...
  17. flume-ng-sdk/src/main/thrift/flume.thrift: Loading...
  18. flume-ng-sdk/src/test/java/org/apache/flume/api/TestThriftRpcClient.java: Loading...
  19. flume-ng-sdk/src/test/java/org/apache/flume/api/ThriftTestingSource.java: Loading...
  20. flume-ng-sources/flume-scribe-source/pom.xml: Loading...
  21. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/LogEntry.java: Loading...
  22. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ResultCode.java: Loading...
  23. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java: Loading...
  24. flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java: Loading...
  25. flume-ng-sources/flume-scribe-source/src/main/thrift/aslv2: Loading...
  26. flume-ng-sources/flume-scribe-source/src/main/thrift/scribe-source.thrift: Loading...