|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use RpcClient | |
---|---|
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 | |
---|---|
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 | |
---|---|
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 | |
---|---|
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |