Review Board 1.7.22


FLUME-1756: Avro client should be able to use load balancing RPC

Review Request #8692 - Created Dec. 20, 2012 and submitted

Mike Percy
FLUME-1756
Reviewers
Flume
flume-git
Avro client should be able to use load balancing RPC.
Manual testing
bin/flume-ng
Revision 4fd1503 New Change
[20] 187 lines
[+20]
188
  --conf-file,-f <file> specify a config file (required)
188
  --conf-file,-f <file> specify a config file (required)
189
  --name,-n <name>      the name of this agent (required)
189
  --name,-n <name>      the name of this agent (required)
190
  --help,-h             display help text
190
  --help,-h             display help text
191

    
   
191

   
192
avro-client options:
192
avro-client options:
193
  --dirname <dir>       directory to stream to avro source
193
  --rpcProps,-P <file>   RPC client properties file with server connection params
194
  --host,-H <host>      hostname to which events will be sent (required)
194
  --host,-H <host>       hostname to which events will be sent
195
  --port,-p <port>      port of the avro source (required)
195
  --port,-p <port>       port of the avro source
196
  --filename,-F <file>  text file to stream to avro source [default: std input]
196
  --dirname <dir>        directory to stream to avro source
197
  --headerFile,-R <file> headerFile containing headers as key/value pairs on each new line
197
  --filename,-F <file>   text file to stream to avro source (default: std input)
198
  --help,-h             display help text
198
  --headerFile,-R <file> File containing event headers as key/value pairs on each new line

    
   
199
  --help,-h              display help text

    
   
200

   

    
   
201
  Either --rpcProps or both --host and --port must be specified.
199

    
   
202

   
200
Note that if <conf> directory is specified, then it is always included first
203
Note that if <conf> directory is specified, then it is always included first
201
in the classpath.
204
in the classpath.
202

    
   
205

   
203
EOF
206
EOF
[+20] [20] 218 lines
flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java
Revision f00ce24 New Change
 
  1. bin/flume-ng: Loading...
  2. flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java: Loading...