Module org.elasticsearch.server

Package org.elasticsearch.index.translog

Class TranslogReader

java.lang.Object

org.elasticsearch.index.translog.BaseTranslogReader

org.elasticsearch.index.translog.TranslogReader

All Implemented Interfaces:

Closeable, AutoCloseable, Comparable<BaseTranslogReader>

public class TranslogReader
extends BaseTranslogReader
implements Closeable

an immutable translog filereader

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicBoolean	closed
protected final long	length

Fields inherited from class org.elasticsearch.index.translog.BaseTranslogReader

channel, generation, header, path

Method Summary

Modifier and Type	Method	Description
final void	close()
protected void	ensureOpen()
long	getLastModifiedTime()
protected final boolean	isClosed()
static TranslogReader	open(FileChannel channel, Path path, org.elasticsearch.index.translog.Checkpoint checkpoint, String translogUUID)	Given a file channel, opens a TranslogReader, taking care of checking and validating the file header.
protected void	readBytes(ByteBuffer buffer, long position)	reads an operation at the given position into the given buffer.
long	sizeInBytes()
int	totalOperations()

Methods inherited from class org.elasticsearch.index.translog.BaseTranslogReader

checksummedStream, compareTo, getFirstOperationOffset, getGeneration, getPrimaryTerm, newSnapshot, path, read, readSize, toString

Methods inherited from class java.lang.Object

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

Field Details

length

protected final long length

closed

protected final AtomicBoolean closed

Method Details

open

public static TranslogReader open(FileChannel channel,
 Path path,
 org.elasticsearch.index.translog.Checkpoint checkpoint,
 String translogUUID)
                           throws IOException

Given a file channel, opens a TranslogReader, taking care of checking and validating the file header.

Parameters:

channel - the translog file channel

path - the path to the translog

checkpoint - the translog checkpoint

translogUUID - the tranlog UUID

Returns:

a new TranslogReader

Throws:

IOException - if any of the file operations resulted in an I/O exception

sizeInBytes

public long sizeInBytes()

Specified by:

sizeInBytes in class BaseTranslogReader

totalOperations

public int totalOperations()

Specified by:

totalOperations in class BaseTranslogReader

readBytes

protected void readBytes(ByteBuffer buffer,
 long position)
                  throws IOException

reads an operation at the given position into the given buffer.

Specified by:

readBytes in class BaseTranslogReader

Throws:

IOException

close

public final void close()
                 throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

isClosed

protected final boolean isClosed()

ensureOpen

protected void ensureOpen()

getLastModifiedTime

public long getLastModifiedTime()
                         throws IOException

Overrides:

getLastModifiedTime in class BaseTranslogReader

Throws:

IOException