org.apache.flume.api
Class NettyAvroRpcClient.Builder

java.lang.Object
  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