|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Sink
A sink is connected to a Channel and consumes its contents, sending them to a configured destination that may vary according to the sink type.
Sinks can be grouped together for various behaviors using SinkGroup and SinkProcessor. They are polled periodically by a SinkRunner via the processor
Sinks are associated with unique names that can be used for separating configuration and working namespaces.
Channel
,
SinkProcessor
,
SinkRunner
Nested Class Summary | |
---|---|
static class |
Sink.Status
|
Method Summary | |
---|---|
Channel |
getChannel()
|
Sink.Status |
process()
Requests the sink to attempt to consume data from attached channel |
void |
setChannel(Channel channel)
Sets the channel the sink will consume from |
Methods inherited from interface org.apache.flume.lifecycle.LifecycleAware |
---|
getLifecycleState, start, stop |
Methods inherited from interface org.apache.flume.NamedComponent |
---|
getName, setName |
Method Detail |
---|
void setChannel(Channel channel)
Sets the channel the sink will consume from
channel
- The channel to be polledChannel getChannel()
Sink.Status process() throws EventDeliveryException
Requests the sink to attempt to consume data from attached channel
Note: This method should be consuming from the channel within the bounds of a Transaction. On successful delivery, the transaction should be committed, and on failure it should be rolled back.
EventDeliveryException
- In case of any kind of failure to
deliver data to the next hop destination.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |