org.apache.flume.channel.file

Class LogFileV3

java.lang.Object

org.apache.flume.channel.file.LogFile

org.apache.flume.channel.file.LogFileV3

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class LogFileV3
extends LogFile

Represents a single data file on disk. Has methods to write, read sequentially (replay), and read randomly (channel takes).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LogFileV3.SequentialReader

Nested classes/interfaces inherited from class org.apache.flume.channel.file.LogFile

LogFile.OperationRecordUpdater

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Fields inherited from class org.apache.flume.channel.file.LogFile

OP_EOF, OP_NOOP, OP_RECORD

Method Summary

Methods

Modifier and Type	Method and Description
static void	writeDelimitedTo(com.google.protobuf.GeneratedMessage msg, File file) Writes a GeneratedMessage to a temp file, synchronizes it to disk and then renames the file over file.

Methods inherited from class org.apache.flume.channel.file.LogFile

main, readDelimitedBuffer, skipRecord, writeDelimitedBuffer

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Method Detail

writeDelimitedTo

public static void writeDelimitedTo(com.google.protobuf.GeneratedMessage msg,
                    File file)
                             throws IOException

Writes a GeneratedMessage to a temp file, synchronizes it to disk and then renames the file over file.

Parameters:

msg - GeneratedMessage to write to the file

file - destination file

Throws:

IOException - if a write error occurs or the File.renameTo method returns false meaning the file could not be overwritten.