Uses of Class
org.apache.flume.FlumeException

Packages that use FlumeException
org.apache.flume   
org.apache.flume.agent.embedded This package provides Flume users the ability to embed simple agents in applications. 
org.apache.flume.api   
org.apache.flume.channel   
org.apache.flume.channel.file   
org.apache.flume.clients.log4jappender   
org.apache.flume.conf   
org.apache.flume.instrumentation   
org.apache.flume.sink   
org.apache.flume.sink.hbase   
org.apache.flume.source   
org.apache.flume.source.http   
org.apache.flume.source.jms   
 

Uses of FlumeException in org.apache.flume
 

Methods in org.apache.flume that throw FlumeException
 Source SourceFactory.create(String sourceName, String type)
           
 Sink SinkFactory.create(String name, String type)
           
 Channel ChannelFactory.create(String name, String type)
           
 Class<? extends Source> SourceFactory.getClass(String type)
           
 Class<? extends Sink> SinkFactory.getClass(String type)
           
 Class<? extends Channel> ChannelFactory.getClass(String type)
           
 

Uses of FlumeException in org.apache.flume.agent.embedded
 

Methods in org.apache.flume.agent.embedded that throw FlumeException
 void EmbeddedAgent.configure(Map<String,String> properties)
          Configures the embedded agent.
 void EmbeddedAgent.start()
          Started the agent.
 void EmbeddedAgent.stop()
          Stops the agent.
 

Uses of FlumeException in org.apache.flume.api
 

Methods in org.apache.flume.api that throw FlumeException
 void ThriftRpcClient.close()
           
 void RpcClient.close()
          Immediately closes the client so that it may no longer be used.
 void NettyAvroRpcClient.close()
           
 void LoadBalancingRpcClient.close()
           
 void FailoverRpcClient.close()
          Close the connection.
abstract  void AbstractRpcClient.close()
           
protected  void ThriftRpcClient.configure(Properties properties)
           
 void NettyAvroRpcClient.configure(Properties properties)
           Configure the actual client using the properties.
protected  void LoadBalancingRpcClient.configure(Properties properties)
           
 void FailoverRpcClient.configure(Properties properties)
           
protected abstract  void AbstractRpcClient.configure(Properties properties)
          Configure the client using the given properties object.
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(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.  
 

Uses of FlumeException in org.apache.flume.channel
 

Methods in org.apache.flume.channel that throw FlumeException
 Channel DefaultChannelFactory.create(String name, String type)
           
 Class<? extends Channel> DefaultChannelFactory.getClass(String type)
           
 

Uses of FlumeException in org.apache.flume.channel.file
 

Subclasses of FlumeException in org.apache.flume.channel.file
 class BadCheckpointException
          Exception thrown when the checkpoint directory contains invalid data, probably due to the channel stopping while the checkpoint was written.
 

Uses of FlumeException in org.apache.flume.clients.log4jappender
 

Methods in org.apache.flume.clients.log4jappender that throw FlumeException
 void Log4jAppender.activateOptions()
          Activate the options set using setPort() and setHostname()
 void LoadBalancingLog4jAppender.activateOptions()
          Activate the options set using setHosts(), setSelector and setMaxBackoff
 void Log4jAppender.append(org.apache.log4j.spi.LoggingEvent event)
          Append the LoggingEvent, to send to the first Flume hop.
 void Log4jAppender.close()
          Closes underlying client.
 

Uses of FlumeException in org.apache.flume.conf
 

Subclasses of FlumeException in org.apache.flume.conf
 class ConfigurationException
           
 

Uses of FlumeException in org.apache.flume.instrumentation
 

Constructors in org.apache.flume.instrumentation that throw FlumeException
GangliaServer()
           
 

Uses of FlumeException in org.apache.flume.sink
 

Methods in org.apache.flume.sink that throw FlumeException
 Sink DefaultSinkFactory.create(String name, String type)
           
 Class<? extends Sink> DefaultSinkFactory.getClass(String type)
           
 

Uses of FlumeException in org.apache.flume.sink.hbase
 

Methods in org.apache.flume.sink.hbase that throw FlumeException
 List<org.apache.hadoop.hbase.client.Row> SimpleHbaseEventSerializer.getActions()
           
 List<org.apache.hadoop.hbase.client.Row> RegexHbaseEventSerializer.getActions()
           
 

Uses of FlumeException in org.apache.flume.source
 

Methods in org.apache.flume.source that throw FlumeException
 Source DefaultSourceFactory.create(String name, String type)
           
protected abstract  void BasicSourceSemantics.doConfigure(Context context)
           
protected abstract  void BasicSourceSemantics.doStart()
           
protected abstract  void BasicSourceSemantics.doStop()
           
 Class<? extends Source> DefaultSourceFactory.getClass(String type)
           
 

Uses of FlumeException in org.apache.flume.source.http
 

Subclasses of FlumeException in org.apache.flume.source.http
 class HTTPBadRequestException
          Exception thrown by an HTTP Handler if the request was not parsed correctly into an event because the request was not in the expected format.
 

Uses of FlumeException in org.apache.flume.source.jms
 

Methods in org.apache.flume.source.jms that throw FlumeException
protected  void JMSSource.doConfigure(Context context)
           
 



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