org.apache.flume.sink.hdfs
Class HDFSEventSink
java.lang.Object
org.apache.flume.sink.AbstractSink
org.apache.flume.sink.hdfs.HDFSEventSink
- All Implemented Interfaces:
- Configurable, LifecycleAware, PollableSink, Sink
public class HDFSEventSink
- extends AbstractSink
- implements PollableSink, Configurable
Method Summary |
void |
configure(Context context)
|
PollableSink.Status |
process()
Pull events out of channel and send it to HDFS - take at the most
txnEventMax, that's the maximum #events to hold in channel for a given
transaction - find the corresponding bucket for the event, ensure the file
is open - extract the pay-load and append to HDFS file |
void |
start()
Starts a service or component. |
void |
stop()
Stops a service or component. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HDFSEventSink
public HDFSEventSink()
HDFSEventSink
public HDFSEventSink(HDFSWriterFactory newWriterFactory)
configure
public void configure(Context context)
- Specified by:
configure
in interface Configurable
process
public PollableSink.Status process()
throws EventDeliveryException
- Pull events out of channel and send it to HDFS - take at the most
txnEventMax, that's the maximum #events to hold in channel for a given
transaction - find the corresponding bucket for the event, ensure the file
is open - extract the pay-load and append to HDFS file
- Specified by:
process
in interface PollableSink
- Throws:
EventDeliveryException
stop
public void stop()
- Description copied from interface:
LifecycleAware
Stops a service or component.
Implementations should determine the result of any stop logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
- Specified by:
stop
in interface LifecycleAware
- Overrides:
stop
in class AbstractSink
start
public void start()
- Description copied from interface:
LifecycleAware
Starts a service or component.
Implementations should determine the result of any start logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
- Specified by:
start
in interface LifecycleAware
- Overrides:
start
in class AbstractSink
Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.