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 |
Internal load-generating source implementation. |
SyslogParser |
|
SyslogSourceConfigurationConstants |
|
SyslogTcpSource |
|
SyslogUDPSource |
|
SyslogUtils |
|
ThriftSource |
|