org.apache.flume.source.taildir

Class TailFile

java.lang.Object

org.apache.flume.source.taildir.TailFile

public class TailFile
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TailFile.CompareByLastModifiedTime

Constructor Summary

Constructors

Constructor and Description
TailFile(File file, Map<String,String> headers, long inode, long pos)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Map<String,String>	getHeaders()
long	getInode()
long	getLastUpdated()
String	getPath()
long	getPos()
RandomAccessFile	getRaf()
boolean	needTail()
List<Event>	readEvents(int numEvents, boolean backoffWithoutNL, boolean addByteOffset)
void	setLastUpdated(long lastUpdated)
void	setNeedTail(boolean needTail)
void	setPos(long pos)
boolean	updatePos(String path, long inode, long pos)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TailFile

public TailFile(File file,
        Map<String,String> headers,
        long inode,
        long pos)
         throws IOException

Throws:

IOException

Method Detail

getRaf

public RandomAccessFile getRaf()

getPath

public String getPath()

getInode

public long getInode()

getPos

public long getPos()

getLastUpdated

public long getLastUpdated()

needTail

public boolean needTail()

getHeaders

public Map<String,String> getHeaders()

setPos

public void setPos(long pos)

setLastUpdated

public void setLastUpdated(long lastUpdated)

setNeedTail

public void setNeedTail(boolean needTail)

updatePos

public boolean updatePos(String path,
                long inode,
                long pos)
                  throws IOException

Throws:

IOException

readEvents

public List<Event> readEvents(int numEvents,
                     boolean backoffWithoutNL,
                     boolean addByteOffset)
                       throws IOException

Throws:

IOException

close

public void close()