Uses of Interface
org.apache.flume.api.RpcClient

Packages that use RpcClient

Package	Description
org.apache.flume.api
org.apache.flume.sink

Uses of RpcClient in org.apache.flume.api

Classes in org.apache.flume.api that implement RpcClient

Modifier and Type	Class and Description
class	AbstractRpcClient
class	FailoverRpcClient Avro/Netty implementation of RpcClient which supports failover.
class	LoadBalancingRpcClient An implementation of RpcClient interface that uses NettyAvroRpcClient instances to load-balance the requests over many different hosts.
class	NettyAvroRpcClient Avro/Netty implementation of RpcClient.
class	SecureThriftRpcClient
class	ThriftRpcClient

Methods in org.apache.flume.api that return RpcClient

Modifier and Type	Method and Description
static RpcClient	RpcClientFactory.getDefaultInstance(String hostname, Integer port) Returns an instance of RpcClient connected to the specified hostname and port.
static RpcClient	RpcClientFactory.getDefaultInstance(String hostname, Integer port, Integer batchSize) Returns an instance of RpcClient connected to the specified hostname and port with the specified batchSize.
static RpcClient	RpcClientFactory.getInstance(File propertiesFile) Delegates to RpcClientFactory.getInstance(Properties props), given a File path to a Properties file.
static RpcClient	RpcClientFactory.getInstance(Properties properties) Returns an instance of RpcClient, optionally with failover.
static RpcClient	RpcClientFactory.getInstance(String hostname, Integer port) Deprecated.
static RpcClient	RpcClientFactory.getInstance(String hostname, Integer port, Integer batchSize) Deprecated.
static RpcClient	SecureRpcClientFactory.getThriftInstance(Properties props) Return a secure RpcClient that uses Thrift for communicating with the next hop.
static RpcClient	RpcClientFactory.getThriftInstance(Properties props) Return an RpcClient that uses Thrift for communicating with the next hop.
static RpcClient	RpcClientFactory.getThriftInstance(String hostname, Integer port) Return an RpcClient that uses Thrift for communicating with the next hop.
static RpcClient	RpcClientFactory.getThriftInstance(String hostname, Integer port, Integer batchSize) Return an RpcClient that uses Thrift for communicating with the next hop.

Uses of RpcClient in org.apache.flume.sink

Methods in org.apache.flume.sink that return RpcClient

Modifier and Type	Method and Description
protected RpcClient	ThriftSink.initializeRpcClient(Properties props)
protected RpcClient	AvroSink.initializeRpcClient(Properties props)
protected abstract RpcClient	AbstractRpcSink.initializeRpcClient(Properties props) Returns a new RpcClient instance configured using the given Properties object.