|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Source | |
---|---|
org.apache.flume | |
org.apache.flume.source | |
org.apache.flume.source.avroLegacy | |
org.apache.flume.source.http | |
org.apache.flume.source.scribe | |
org.apache.flume.source.thriftLegacy |
Uses of Source in org.apache.flume |
---|
Subinterfaces of Source in org.apache.flume | |
---|---|
interface |
EventDrivenSource
A Source that does not need an external driver to poll for
events to ingest; it provides its own event-driven
mechanism to invoke event processing. |
interface |
PollableSource
A Source that requires an external driver to poll to determine
whether there are events that are available to ingest
from the source. |
Methods in org.apache.flume that return Source | |
---|---|
Source |
SourceFactory.create(String sourceName,
String type)
|
Source |
SourceRunner.getSource()
|
Methods in org.apache.flume with parameters of type Source | |
---|---|
static SourceRunner |
SourceRunner.forSource(Source source)
Static factory method to instantiate a source runner implementation that corresponds to the type of Source specified. |
void |
SourceRunner.setSource(Source source)
|
boolean |
SourceFactory.unregister(Source source)
|
Uses of Source in org.apache.flume.source |
---|
Classes in org.apache.flume.source that implement Source | |
---|---|
class |
AbstractSource
|
class |
AvroSource
A Source implementation that receives Avro events from clients that
implement AvroSourceProtocol . |
class |
ExecSource
A Source implementation that executes a Unix process and turns each
line of text into an event. |
class |
MultiportSyslogTCPSource
|
class |
NetcatSource
A netcat-like source that listens on a given port and turns each line of text into an event. |
class |
SequenceGeneratorSource
|
class |
SpoolDirectorySource
|
class |
StressSource
Internal load-generating source implementation. |
class |
SyslogTcpSource
|
class |
SyslogUDPSource
|
Methods in org.apache.flume.source that return Source | |
---|---|
Source |
DefaultSourceFactory.create(String name,
String type)
|
Methods in org.apache.flume.source that return types with arguments of type Source | |
---|---|
Map<Class<?>,Map<String,Source>> |
DefaultSourceFactory.getRegistryClone()
|
Methods in org.apache.flume.source with parameters of type Source | |
---|---|
boolean |
DefaultSourceFactory.unregister(Source source)
|
Uses of Source in org.apache.flume.source.avroLegacy |
---|
Classes in org.apache.flume.source.avroLegacy that implement Source | |
---|---|
class |
AvroLegacySource
A Source implementation that receives Avro events from Avro sink of
Flume OG |
Uses of Source in org.apache.flume.source.http |
---|
Classes in org.apache.flume.source.http that implement Source | |
---|---|
class |
HTTPSource
A source which accepts Flume Events by HTTP POST and GET. |
Uses of Source in org.apache.flume.source.scribe |
---|
Classes in org.apache.flume.source.scribe that implement Source | |
---|---|
class |
ScribeSource
Flume should adopt the Scribe entry LogEntry from existing
Scribe system. |
Uses of Source in org.apache.flume.source.thriftLegacy |
---|
Classes in org.apache.flume.source.thriftLegacy that implement Source | |
---|---|
class |
ThriftLegacySource
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |