org.elasticsearch.index.translog

Class TranslogWriter

java.lang.Object

org.elasticsearch.index.translog.BaseTranslogReader

org.elasticsearch.index.translog.TranslogWriter

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Comparable<BaseTranslogReader>

public class TranslogWriter
extends BaseTranslogReader
implements java.io.Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicBoolean	closed
static java.lang.String	TRANSLOG_CODEC
static int	VERSION
static int	VERSION_CHECKPOINTS
static int	VERSION_CHECKSUMS

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

channel, firstOperationOffset, generation, path

Constructor Summary

Constructors

Constructor and Description
TranslogWriter(org.elasticsearch.index.translog.ChannelFactory channelFactory, ShardId shardId, long generation, java.nio.channels.FileChannel channel, java.nio.file.Path path, ByteSizeValue bufferSize)

Method Summary

Modifier and Type	Method and Description
Translog.Location	add(BytesReference data) add the given bytes to the translog and return the location they were written at
void	close()
TranslogReader	closeIntoReader() closes this writer and transfers it's underlying file channel to a new immutable reader
static TranslogWriter	create(ShardId shardId, java.lang.String translogUUID, long fileGeneration, java.nio.file.Path file, org.elasticsearch.index.translog.ChannelFactory channelFactory, ByteSizeValue bufferSize)
protected void	ensureOpen()
java.lang.Exception	getTragicException() If this TranslogWriter was closed as a side-effect of a tragic exception, e.g.
protected boolean	isClosed()
Translog.Snapshot	newSnapshot()
protected void	readBytes(java.nio.ByteBuffer targetBuffer, long position) reads bytes at position into the given buffer, filling it.
long	sizeInBytes()
void	sync() write all buffered ops to disk and fsync file.
boolean	syncNeeded() returns true if there are buffered ops
boolean	syncUpTo(long offset) Syncs the translog up to at least the given offset unless already synced
int	totalOperations()

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

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

Methods inherited from class java.lang.Object

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

Field Detail

TRANSLOG_CODEC

public static final java.lang.String TRANSLOG_CODEC

See Also:

Constant Field Values

VERSION_CHECKSUMS

public static final int VERSION_CHECKSUMS

See Also:

Constant Field Values

VERSION_CHECKPOINTS

public static final int VERSION_CHECKPOINTS

See Also:

Constant Field Values

VERSION

public static final int VERSION

See Also:

Constant Field Values

closed

protected final java.util.concurrent.atomic.AtomicBoolean closed

Constructor Detail

TranslogWriter

public TranslogWriter(org.elasticsearch.index.translog.ChannelFactory channelFactory,
                      ShardId shardId,
                      long generation,
                      java.nio.channels.FileChannel channel,
                      java.nio.file.Path path,
                      ByteSizeValue bufferSize)
               throws java.io.IOException

Throws:

java.io.IOException

Method Detail

create

public static TranslogWriter create(ShardId shardId,
                                    java.lang.String translogUUID,
                                    long fileGeneration,
                                    java.nio.file.Path file,
                                    org.elasticsearch.index.translog.ChannelFactory channelFactory,
                                    ByteSizeValue bufferSize)
                             throws java.io.IOException

Throws:

java.io.IOException

getTragicException

public java.lang.Exception getTragicException()

If this TranslogWriter was closed as a side-effect of a tragic exception, e.g. disk full while flushing a new segment, this returns the root cause exception. Otherwise (no tragic exception has occurred) it returns null.

add

public Translog.Location add(BytesReference data)
                      throws java.io.IOException

add the given bytes to the translog and return the location they were written at

Throws:

java.io.IOException

sync

public void sync()
          throws java.io.IOException

write all buffered ops to disk and fsync file. Note: any exception during the sync process will be interpreted as a tragic exception and the writer will be closed before raising the exception.

Throws:

java.io.IOException

syncNeeded

public boolean syncNeeded()

returns true if there are buffered ops

totalOperations

public int totalOperations()

Specified by:

totalOperations in class BaseTranslogReader

sizeInBytes

public long sizeInBytes()

Specified by:

sizeInBytes in class BaseTranslogReader

closeIntoReader

public TranslogReader closeIntoReader()
                               throws java.io.IOException

closes this writer and transfers it's underlying file channel to a new immutable reader

Throws:

java.io.IOException

newSnapshot

public Translog.Snapshot newSnapshot()

Overrides:

newSnapshot in class BaseTranslogReader

syncUpTo

public boolean syncUpTo(long offset)
                 throws java.io.IOException

Syncs the translog up to at least the given offset unless already synced

Returns:

true if this call caused an actual sync operation

Throws:

java.io.IOException

readBytes

protected void readBytes(java.nio.ByteBuffer targetBuffer,
                         long position)
                  throws java.io.IOException

Description copied from class: BaseTranslogReader

reads bytes at position into the given buffer, filling it.

Specified by:

readBytes in class BaseTranslogReader

Throws:

java.io.IOException

ensureOpen

protected final void ensureOpen()

close

public final void close()
                 throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

isClosed

protected final boolean isClosed()