org.elasticsearch.index.translog.fs

Class SimpleFsTranslogFile

java.lang.Object

org.elasticsearch.index.translog.fs.SimpleFsTranslogFile

All Implemented Interfaces:

FsTranslogFile

public class SimpleFsTranslogFile
extends Object
implements FsTranslogFile

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.index.translog.fs.FsTranslogFile

FsTranslogFile.Type

Constructor Summary

Constructors

Constructor and Description
SimpleFsTranslogFile(ShardId shardId, long id, RafReference raf)

Method Summary

Modifier and Type	Method and Description
Translog.Location	add(BytesReference data)
void	close(boolean delete)
boolean	closed()
int	estimatedNumberOfOperations()
TranslogStream	getStream()
long	id()
byte[]	read(Translog.Location location)
void	reuse(FsTranslogFile other)
FsChannelSnapshot	snapshot() Returns a snapshot on this file, null if it failed to snapshot.
void	sync()
boolean	syncNeeded()
String	toString()
long	translogSizeInBytes()
void	updateBufferSize(int bufferSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleFsTranslogFile

public SimpleFsTranslogFile(ShardId shardId,
                            long id,
                            RafReference raf)
                     throws IOException

Throws:

IOException

Method Detail

id

public long id()

Specified by:

id in interface FsTranslogFile

estimatedNumberOfOperations

public int estimatedNumberOfOperations()

Specified by:

estimatedNumberOfOperations in interface FsTranslogFile

translogSizeInBytes

public long translogSizeInBytes()

Specified by:

translogSizeInBytes in interface FsTranslogFile

add

public Translog.Location add(BytesReference data)
                      throws IOException

Specified by:

add in interface FsTranslogFile

Throws:

IOException

read

public byte[] read(Translog.Location location)
            throws IOException

Specified by:

read in interface FsTranslogFile

Throws:

IOException

close

public void close(boolean delete)

Specified by:

close in interface FsTranslogFile

snapshot

public FsChannelSnapshot snapshot()
                           throws TranslogException

Returns a snapshot on this file, null if it failed to snapshot.

Specified by:

snapshot in interface FsTranslogFile

Throws:

TranslogException

syncNeeded

public boolean syncNeeded()

Specified by:

syncNeeded in interface FsTranslogFile

getStream

public TranslogStream getStream()

Specified by:

getStream in interface FsTranslogFile

sync

public void sync()
          throws IOException

Specified by:

sync in interface FsTranslogFile

Throws:

IOException

reuse

public void reuse(FsTranslogFile other)

Specified by:

reuse in interface FsTranslogFile

updateBufferSize

public void updateBufferSize(int bufferSize)
                      throws TranslogException

Specified by:

updateBufferSize in interface FsTranslogFile

Throws:

TranslogException

toString

public String toString()

Overrides:

toString in class Object

closed

public boolean closed()

Specified by:

closed in interface FsTranslogFile