org.elasticsearch.index.translog.fs

Class BufferingFsTranslogFile

java.lang.Object

org.elasticsearch.index.translog.fs.BufferingFsTranslogFile

All Implemented Interfaces:

FsTranslogFile

public class BufferingFsTranslogFile
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
BufferingFsTranslogFile(ShardId shardId, long id, RafReference raf, int bufferSize)

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

BufferingFsTranslogFile

public BufferingFsTranslogFile(ShardId shardId,
                               long id,
                               RafReference raf,
                               int bufferSize)
                        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

snapshot

public FsChannelSnapshot snapshot()
                           throws TranslogException

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

close

public void close(boolean delete)

Specified by:

close in interface FsTranslogFile

reuse

public void reuse(FsTranslogFile other)

Specified by:

reuse in interface FsTranslogFile

updateBufferSize

public void updateBufferSize(int bufferSize)

Specified by:

updateBufferSize in interface FsTranslogFile

closed

public boolean closed()

Specified by:

closed in interface FsTranslogFile

toString

public String toString()

Overrides:

toString in class Object