public class TranslogDeletionPolicy
extends java.lang.Object
Constructor | Description |
---|---|
TranslogDeletionPolicy(long retentionSizeInBytes,
long retentionAgeInMillis) |
Modifier and Type | Method | Description |
---|---|---|
void |
assertNoOpenTranslogRefs() |
|
protected long |
currentTime() |
|
long |
getMinTranslogGenerationForRecovery() |
returns the translog generation that will be used as a basis of a future store/peer recovery
|
long |
getTranslogGenerationOfLastCommit() |
Returns a translog generation that will be used to calculate the number of uncommitted operations since the last index commit.
|
void |
setMinTranslogGenerationForRecovery(long newGen) |
|
void |
setRetentionAgeInMillis(long ageInMillis) |
|
void |
setRetentionSizeInBytes(long bytes) |
|
void |
setTranslogGenerationOfLastCommit(long lastGen) |
Sets the translog generation of the last index commit.
|
public TranslogDeletionPolicy(long retentionSizeInBytes, long retentionAgeInMillis)
public void assertNoOpenTranslogRefs()
public void setMinTranslogGenerationForRecovery(long newGen)
public void setTranslogGenerationOfLastCommit(long lastGen)
public void setRetentionSizeInBytes(long bytes)
public void setRetentionAgeInMillis(long ageInMillis)
protected long currentTime()
public long getMinTranslogGenerationForRecovery()
public long getTranslogGenerationOfLastCommit()