Package org.elasticsearch.index.translog

Class TranslogDeletionPolicy

java.lang.Object

org.elasticsearch.index.translog.TranslogDeletionPolicy

public class TranslogDeletionPolicy
extends Object

Constructor Summary

Constructors

Constructor	Description
TranslogDeletionPolicy(long retentionSizeInBytes, long retentionAgeInMillis, int retentionTotalFiles)

Method Summary

Modifier and Type	Method	Description
void	assertNoOpenTranslogRefs()
protected long	currentTime()
long	getLocalCheckpointOfSafeCommit()	Returns the local checkpoint of the safe commit.
void	setLocalCheckpointOfSafeCommit(long newCheckpoint)
void	setRetentionAgeInMillis(long ageInMillis)
void	setRetentionSizeInBytes(long bytes)

Methods inherited from class java.lang.Object

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

Constructor Details

TranslogDeletionPolicy

public TranslogDeletionPolicy(long retentionSizeInBytes,
 long retentionAgeInMillis,
 int retentionTotalFiles)

Method Details

assertNoOpenTranslogRefs

public void assertNoOpenTranslogRefs()

setLocalCheckpointOfSafeCommit

public void setLocalCheckpointOfSafeCommit(long newCheckpoint)

setRetentionSizeInBytes

public void setRetentionSizeInBytes(long bytes)

setRetentionAgeInMillis

public void setRetentionAgeInMillis(long ageInMillis)

currentTime

protected long currentTime()

getLocalCheckpointOfSafeCommit

public long getLocalCheckpointOfSafeCommit()

Returns the local checkpoint of the safe commit. This value is used to calculate the min required generation for recovery.