Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.node | |
org.apache.flume.source |
Modifier and Type | Method and Description |
---|---|
static SourceRunner |
SourceRunner.forSource(Source source)
Static factory method to instantiate a source runner implementation that
corresponds to the type of
Source specified. |
Modifier and Type | Method and Description |
---|---|
Map<String,SourceRunner> |
SimpleMaterializedConfiguration.getSourceRunners() |
Map<String,SourceRunner> |
MaterializedConfiguration.getSourceRunners() |
Modifier and Type | Method and Description |
---|---|
void |
SimpleMaterializedConfiguration.addSourceRunner(String name,
SourceRunner sourceRunner) |
void |
MaterializedConfiguration.addSourceRunner(String name,
SourceRunner sourceRunner) |
Modifier and Type | Class and Description |
---|---|
class |
EventDrivenSourceRunner
Starts, stops, and manages
event-driven sources.
|
class |
PollableSourceRunner
An implementation of
SourceRunner that can drive a
PollableSource . |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.