org.apache.flume.api
Class NettyAvroRpcClient.Builder

java.lang.Object
  extended by org.apache.flume.api.NettyAvroRpcClient.Builder
Enclosing class:
NettyAvroRpcClient

protected static class NettyAvroRpcClient.Builder
extends Object

Builder class used to construct NettyAvroRpcClient objects.

Note: It is recommended for applications to construct RpcClient instances using the RpcClientFactory class.


Field Summary
protected static int DEFAULT_BATCH_SIZE
           
 
Constructor Summary
NettyAvroRpcClient.Builder()
           
 
Method Summary
 NettyAvroRpcClient.Builder batchSize(Integer batchSize)
          Maximum number of events that can be processed in a batch operation.
 NettyAvroRpcClient build()
          Construct the object
 NettyAvroRpcClient.Builder hostname(String hostname)
          Hostname to connect to (required)
 NettyAvroRpcClient.Builder port(Integer port)
          Port to connect to (required)
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_BATCH_SIZE

protected static final int DEFAULT_BATCH_SIZE
See Also:
Constant Field Values
Constructor Detail

NettyAvroRpcClient.Builder

public NettyAvroRpcClient.Builder()
Method Detail

hostname

public NettyAvroRpcClient.Builder hostname(String hostname)
Hostname to connect to (required)

Parameters:
hostname -
Returns:
this

port

public NettyAvroRpcClient.Builder port(Integer port)
Port to connect to (required)

Parameters:
port -
Returns:
this

batchSize

public NettyAvroRpcClient.Builder batchSize(Integer batchSize)
Maximum number of events that can be processed in a batch operation. (optional)
Default: 100

Parameters:
batchSize -
Returns:
this

build

public NettyAvroRpcClient build()
                         throws FlumeException
Construct the object

Returns:
Active RPC client
Throws:
FlumeException


Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.