org.apache.flume.channel.file
Class LogFile

java.lang.Object
  org.apache.flume.channel.file.LogFile

Direct Known Subclasses:

LogFileV3

@InterfaceAudience.Private
@InterfaceStability.Unstable
public abstract class LogFile
extends Object

Nested Class Summary

static class	LogFile.OperationRecordUpdater This is an class meant to be an internal Flume API, and can change at any time.
static class	LogFile.SequentialReader

Field Summary

static byte	OP_EOF
static byte	OP_NOOP
static byte	OP_RECORD

Constructor Summary

LogFile()

Method Summary

static void	main(String[] args)
protected static byte[]	readDelimitedBuffer(RandomAccessFile fileHandle)
protected static void	skipRecord(RandomAccessFile fileHandle, int offset)
protected static void	writeDelimitedBuffer(ByteBuffer output, ByteBuffer buffer)

Methods inherited from class java.lang.Object

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

Field Detail

OP_RECORD

public static final byte OP_RECORD

See Also:

Constant Field Values

OP_NOOP

public static final byte OP_NOOP

See Also:

Constant Field Values

OP_EOF

public static final byte OP_EOF

See Also:

Constant Field Values

Constructor Detail

LogFile

public LogFile()

Method Detail

skipRecord

protected static void skipRecord(RandomAccessFile fileHandle,
                                 int offset)
                          throws IOException

Throws:

IOException

writeDelimitedBuffer

protected static void writeDelimitedBuffer(ByteBuffer output,
                                           ByteBuffer buffer)
                                    throws IOException

Throws:

IOException

readDelimitedBuffer

protected static byte[] readDelimitedBuffer(RandomAccessFile fileHandle)
                                     throws IOException,
                                            CorruptEventException

Throws:

IOException

CorruptEventException

main

public static void main(String[] args)
                 throws EOFException,
                        IOException,
                        CorruptEventException

Throws:

EOFException

IOException

CorruptEventException