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
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent
org.elasticsearch.common.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.common.xcontent.ToXContent.MapParams, org.elasticsearch.common.xcontent.ToXContent.Params
Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V>
-
Field Summary
Fields Modifier and Type Field Description static int
UNKNOWN
Fields inherited from class org.elasticsearch.indices.recovery.RecoveryState.Timer
startNanoTime, startTime, stopTime, time
-
Constructor Summary
Constructors Constructor Description Translog()
Translog(StreamInput in)
-
Method Summary
Modifier and Type Method Description void
decrementRecoveredOperations(int ops)
void
incrementRecoveredOperations()
void
incrementRecoveredOperations(int ops)
int
recoveredOperations()
returns the total number of translog operations recovered so farfloat
recoveredPercent()
void
reset()
int
totalLocal()
void
totalLocal(int totalLocal)
Sets the total number of translog operations to be recovered locally before performing peer recoveryint
totalOperations()
returns the total number of translog operations needed to be recovered at this moment.void
totalOperations(int total)
int
totalOperationsOnStart()
returns the total number of translog operations to recovered, on the start of the recovery.void
totalOperationsOnStart(int total)
org.elasticsearch.common.xcontent.XContentBuilder
toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params)
void
writeTo(StreamOutput out)
Write this into the StreamOutput.Methods inherited from class org.elasticsearch.indices.recovery.RecoveryState.Timer
getStartNanoTime, start, startTime, stop, stopTime, time
-
Field Details
-
UNKNOWN
public static final int UNKNOWN- See Also:
- Constant Field Values
-
-
Constructor Details
-
Method Details
-
writeTo
Description copied from interface:Writeable
Write this into the StreamOutput.- Specified by:
writeTo
in interfaceWriteable
- Overrides:
writeTo
in classRecoveryState.Timer
- Throws:
java.io.IOException
-
reset
public void reset()- Overrides:
reset
in classRecoveryState.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. UnliketotalOperations()
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 -
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 java.io.IOException- Specified by:
toXContent
in interfaceorg.elasticsearch.common.xcontent.ToXContent
- Throws:
java.io.IOException
-