Class | Description |
---|---|
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 | |
NetcatUdpSource | |
PollableSourceConstants | |
PollableSourceRunner |
An implementation of
SourceRunner that can drive a
PollableSource . |
PollableSourceRunner.PollingRunner | |
SequenceGeneratorSource | |
SpoolDirectorySource | |
SpoolDirectorySourceConfigurationConstants | |
SslContextAwareAbstractSource | |
StressSource |
StressSource is an internal load-generating source implementation
which is very useful for stress tests.
|
SyslogParser | |
SyslogSourceConfigurationConstants | |
SyslogTcpSource | Deprecated
use
MultiportSyslogTCPSource instead. |
SyslogUDPSource | |
SyslogUtils | |
ThriftSource |
Enum | Description |
---|---|
SpoolDirectorySourceConfigurationConstants.ConsumeOrder |
Consume order.
|
SyslogUtils.SyslogStatus |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.