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 10

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...