Class TranslogDeletionPolicy

java.lang.Object
org.elasticsearch.index.translog.TranslogDeletionPolicy

public class TranslogDeletionPolicy
extends java.lang.Object
  • 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.