org.elasticsearch.index.translog

Class ChecksummedTranslogStream

java.lang.Object

org.elasticsearch.index.translog.ChecksummedTranslogStream

All Implemented Interfaces:

TranslogStream

public class ChecksummedTranslogStream
extends Object
implements TranslogStream

Version 1 of the translog file format. Writes a header to identify the format, also writes checksums for each operation

Field Summary

Fields

Modifier and Type	Field and Description
static int	VERSION

Method Summary

Modifier and Type	Method and Description
StreamInput	openInput(File translogFile) Seek past the header, if any header is present
Translog.Operation	read(StreamInput inStream) Read the next translog operation from the input stream
void	write(StreamOutput outStream, Translog.Operation op) Write the given translog operation to the output stream
int	writeHeader(FileChannel channel) Optionally write a header identifying the translog version to the file channel

Methods inherited from class java.lang.Object

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

Field Detail

VERSION

public static final int VERSION

See Also:

Constant Field Values

Method Detail

read

public Translog.Operation read(StreamInput inStream)
                        throws IOException

Description copied from interface: TranslogStream

Read the next translog operation from the input stream

Specified by:

read in interface TranslogStream

Throws:

IOException

write

public void write(StreamOutput outStream,
                  Translog.Operation op)
           throws IOException

Description copied from interface: TranslogStream

Write the given translog operation to the output stream

Specified by:

write in interface TranslogStream

Throws:

IOException

writeHeader

public int writeHeader(FileChannel channel)
                throws IOException

Description copied from interface: TranslogStream

Optionally write a header identifying the translog version to the file channel

Specified by:

writeHeader in interface TranslogStream

Throws:

IOException

openInput

public StreamInput openInput(File translogFile)
                      throws IOException

Description copied from interface: TranslogStream

Seek past the header, if any header is present

Specified by:

openInput in interface TranslogStream

Throws:

IOException