org.apache.hadoop.chukwa.datacollection.adaptor.filetailer

Class FileTailingAdaptor

java.lang.Object

org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.LWFTAdaptor

org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

All Implemented Interfaces:

Adaptor

Direct Known Subclasses:

CharFileTailingAdaptorUTF8, CharFileTailingAdaptorUTF8NewLineEscaped, FileTailingAdaptorPreserveLines

public class FileTailingAdaptor
extends LWFTAdaptor

An adaptor that repeatedly tails a specified file, sending the new bytes. This class does not split out records, but just sends everything up to end of file. Subclasses can alter this behavior by overriding extractRecords().

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_RETRIES

Fields inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.LWFTAdaptor

DEFAULT_MAX_READ_SIZE, MAX_READ_SIZE_OPT

Constructor Summary

Constructors

Constructor and Description
FileTailingAdaptor()

Method Summary

Modifier and Type	Method and Description
long	shutdown(AdaptorShutdownPolicy shutdownPolicy) Signals this adaptor to come to an orderly stop.
void	start(long bytes)
boolean	tailFile() Looks at the tail of the associated file, adds some of it to event queue This method is not thread safe.

Methods inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.LWFTAdaptor

getCurrentStatus, getStreamName, parseArgs, toString

Methods inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

deregisterAndStop, getType, hardStop, parseArgs, shutdown, start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

MAX_RETRIES

public static int MAX_RETRIES

Constructor Detail

FileTailingAdaptor

public FileTailingAdaptor()

Method Detail

start

public void start(long bytes)

Overrides:

start in class LWFTAdaptor

shutdown

public long shutdown(AdaptorShutdownPolicy shutdownPolicy)

Description copied from interface: Adaptor

Signals this adaptor to come to an orderly stop. The adaptor ought to push out all the data it can before exiting depending of the shutdown policy

Specified by:

shutdown in interface Adaptor

Overrides:

shutdown in class LWFTAdaptor

Parameters:

shutdownPolicy - is defined as forcefully or gracefully

Returns:

the logical offset at which the adaptor was when the method return

tailFile

public boolean tailFile()
                 throws InterruptedException

Looks at the tail of the associated file, adds some of it to event queue This method is not thread safe. Returns true if there's more data in the file

Overrides:

tailFile in class LWFTAdaptor

Throws:

InterruptedException