Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.source | |
org.apache.flume.source.jms | |
org.apache.flume.source.kafka | |
org.apache.flume.source.taildir |
Modifier and Type | Method and Description |
---|---|
PollableSource.Status |
PollableSource.process()
Attempt to pull an item from the source, sending it to the channel.
|
static PollableSource.Status |
PollableSource.Status.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static PollableSource.Status[] |
PollableSource.Status.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
protected PollableSource.Status |
StressSource.doProcess() |
protected abstract PollableSource.Status |
AbstractPollableSource.doProcess() |
protected PollableSource.Status |
SequenceGeneratorSource.doProcess() |
PollableSource.Status |
AbstractPollableSource.process() |
Modifier and Type | Method and Description |
---|---|
protected PollableSource.Status |
JMSSource.doProcess() |
Modifier and Type | Method and Description |
---|---|
protected PollableSource.Status |
KafkaSource.doProcess() |
Modifier and Type | Method and Description |
---|---|
PollableSource.Status |
TaildirSource.process() |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.