org.apache.flume
Interface PollableSource

All Superinterfaces:

LifecycleAware, NamedComponent, Source

All Known Implementing Classes:

SequenceGeneratorSource

public interface PollableSource
extends Source

A Source that requires an external driver to poll to determine whether there are events that are available to ingest from the source.

See Also:

EventDrivenSourceRunner

Nested Class Summary

static class

PollableSource.Status

Method Summary

PollableSource.Status

process()

Methods inherited from interface org.apache.flume.Source

getChannelProcessor, setChannelProcessor

Methods inherited from interface org.apache.flume.lifecycle.LifecycleAware

getLifecycleState, start, stop

Methods inherited from interface org.apache.flume.NamedComponent

getName, setName

Method Detail

process

PollableSource.Status process()
                              throws EventDeliveryException

Throws:

EventDeliveryException