Package org.elasticsearch.index.translog

Class TranslogWriter

java.lang.Object

org.elasticsearch.index.translog.BaseTranslogReader

org.elasticsearch.index.translog.TranslogWriter

All Implemented Interfaces:

Closeable, AutoCloseable, Comparable<BaseTranslogReader>

public class TranslogWriter
extends BaseTranslogReader
implements Closeable

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicBoolean	closed

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

channel, generation, header, path

Method Summary

Modifier and Type	Method	Description
Translog.Location	add(BytesReference data, long seqNo)	Add the given bytes to the translog with the specified sequence number; returns the location the bytes were written to.
final void	close()
TranslogReader	closeIntoReader()	Closes this writer and transfers its underlying file channel to a new immutable TranslogReader
static TranslogWriter	create(ShardId shardId, String translogUUID, long fileGeneration, Path file, ChannelFactory channelFactory, ByteSizeValue bufferSize, long initialMinTranslogGen, long initialGlobalCheckpoint, LongSupplier globalCheckpointSupplier, LongSupplier minTranslogGenerationSupplier, long primaryTerm, TragicExceptionHolder tragedy, LongConsumer persistedSequenceNumberConsumer, BigArrays bigArrays, DiskIoBufferPool diskIoBufferPool)
protected final void	ensureOpen()
protected final boolean	isClosed()
org.elasticsearch.index.translog.TranslogSnapshot	newSnapshot()
protected void	readBytes(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 operations that have not been flushed and fsynced to disk or if the latest global checkpoint has not yet been fsynced
int	totalOperations()

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

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

Methods inherited from class java.lang.Object

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

Field Details

closed

protected final AtomicBoolean closed

Method Details

create

public static TranslogWriter create(ShardId shardId,
 String translogUUID,
 long fileGeneration,
 Path file,
 ChannelFactory channelFactory,
 ByteSizeValue bufferSize,
 long initialMinTranslogGen,
 long initialGlobalCheckpoint,
 LongSupplier globalCheckpointSupplier,
 LongSupplier minTranslogGenerationSupplier,
 long primaryTerm,
 TragicExceptionHolder tragedy,
 LongConsumer persistedSequenceNumberConsumer,
 BigArrays bigArrays,
 DiskIoBufferPool diskIoBufferPool)
                             throws IOException

Throws:

IOException

add

public Translog.Location add(BytesReference data,
 long seqNo)
                      throws IOException

Add the given bytes to the translog with the specified sequence number; returns the location the bytes were written to.

Parameters:

data - the bytes to write

seqNo - the sequence number associated with the operation

Returns:

the location the bytes were written to

Throws:

IOException - if writing to the translog resulted in an I/O exception

sync

public void sync()
          throws 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:

IOException

syncNeeded

public boolean syncNeeded()

Returns true if there are buffered operations that have not been flushed and fsynced to disk or if the latest global checkpoint has not yet been fsynced

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 IOException

Closes this writer and transfers its underlying file channel to a new immutable TranslogReader

Returns:

a new TranslogReader

Throws:

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

newSnapshot

public org.elasticsearch.index.translog.TranslogSnapshot newSnapshot()

Overrides:

newSnapshot in class BaseTranslogReader

readBytes

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

Description copied from class: BaseTranslogReader

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

Specified by:

readBytes in class BaseTranslogReader

Throws:

IOException

ensureOpen

protected final void ensureOpen()

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()