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

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.
 



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