org.apache.flume.sink
Class RollingFileSink
java.lang.Object
org.apache.flume.sink.AbstractSink
org.apache.flume.sink.RollingFileSink
- All Implemented Interfaces:
- Configurable, LifecycleAware, PollableSink, Sink
public class RollingFileSink
- extends AbstractSink
- implements PollableSink, Configurable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RollingFileSink
public RollingFileSink()
configure
public void configure(Context context)
- Specified by:
configure
in interface Configurable
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
process
public PollableSink.Status process()
throws EventDeliveryException
- 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
getDirectory
public File getDirectory()
setDirectory
public void setDirectory(File directory)
getRollInterval
public long getRollInterval()
setRollInterval
public void setRollInterval(long rollInterval)
getFormatter
public EventFormatter getFormatter()
setFormatter
public void setFormatter(EventFormatter formatter)
Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.