Class RecoveryState.Translog

java.lang.Object
org.elasticsearch.indices.recovery.RecoveryState.Timer
org.elasticsearch.indices.recovery.RecoveryState.Translog
All Implemented Interfaces:
Writeable, org.elasticsearch.common.xcontent.ToXContent, org.elasticsearch.common.xcontent.ToXContentFragment
Enclosing class:
RecoveryState

public static class RecoveryState.Translog extends RecoveryState.Timer implements org.elasticsearch.common.xcontent.ToXContentFragment, Writeable
  • Field Details

  • Constructor Details

  • Method Details

    • writeTo

      public void writeTo(StreamOutput out) throws IOException
      Description copied from interface: Writeable
      Write this into the StreamOutput.
      Specified by:
      writeTo in interface Writeable
      Overrides:
      writeTo in class RecoveryState.Timer
      Throws:
      IOException
    • reset

      public void reset()
      Overrides:
      reset in class RecoveryState.Timer
    • incrementRecoveredOperations

      public void incrementRecoveredOperations()
    • incrementRecoveredOperations

      public void incrementRecoveredOperations(int ops)
    • decrementRecoveredOperations

      public void decrementRecoveredOperations(int ops)
    • recoveredOperations

      public int recoveredOperations()
      returns the total number of translog operations recovered so far
    • totalOperations

      public int totalOperations()
      returns the total number of translog operations needed to be recovered at this moment. Note that this can change as the number of operations grows during recovery.

      A value of -1 (UNKNOWN is return if this is unknown (typically a gateway recovery)

    • totalOperations

      public void totalOperations(int total)
    • totalOperationsOnStart

      public int totalOperationsOnStart()
      returns the total number of translog operations to recovered, on the start of the recovery. Unlike totalOperations() this does change during recovery.

      A value of -1 (UNKNOWN is return if this is unknown (typically a gateway recovery)

    • totalOperationsOnStart

      public void totalOperationsOnStart(int total)
    • totalLocal

      public void totalLocal(int totalLocal)
      Sets the total number of translog operations to be recovered locally before performing peer recovery
      See Also:
      IndexShard.recoverLocallyUpToGlobalCheckpoint()
    • totalLocal

      public int totalLocal()
    • recoveredPercent

      public float recoveredPercent()
    • toXContent

      public org.elasticsearch.common.xcontent.XContentBuilder toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params) throws IOException
      Specified by:
      toXContent in interface org.elasticsearch.common.xcontent.ToXContent
      Throws:
      IOException