Package org.apache.flume.source

Class Summary
AbstractEventDrivenSource Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics.
AbstractPollableSource Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics in addition to: Ensuring when configure/start throw an exception process will not be called Ensure that process will not be called unless configure and start have successfully been called
AbstractSource  
AvroSource A Source implementation that receives Avro events from clients that implement AvroSourceProtocol.
BasicSourceSemantics Alternative to AbstractSource, which: Ensure configure cannot be called while started Exceptions thrown during configure, start, stop put source in ERROR state Exceptions thrown during start, stop will be logged but not re-thrown. Exception in configure disables starting
DefaultSourceFactory  
EventDrivenSourceRunner Starts, stops, and manages event-driven sources.
ExecSource A Source implementation that executes a Unix process and turns each line of text into an event.
ExecSourceConfigurationConstants  
MultiportSyslogTCPSource  
NetcatSource A netcat-like source that listens on a given port and turns each line of text into an event.
NetcatSourceConfigurationConstants  
PollableSourceRunner An implementation of SourceRunner that can drive a PollableSource.
PollableSourceRunner.PollingRunner  
SequenceGeneratorSource  
SpoolDirectorySource  
SpoolDirectorySourceConfigurationConstants  
StressSource StressSource is an internal load-generating source implementation which is very useful for stress tests.
SyslogParser  
SyslogSourceConfigurationConstants  
SyslogTcpSource  
SyslogUDPSource  
SyslogUtils  
ThriftSource  
 

Enum Summary
SpoolDirectorySourceConfigurationConstants.ConsumeOrder Consume order.
SyslogUtils.SyslogStatus  
 



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