public static class RecoveryState.Translog extends RecoveryState.Timer implements ToXContent, Streamable
ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params
Modifier and Type | Field and Description |
---|---|
static int |
UNKNOWN |
startNanoTime, startTime, stopTime, time
EMPTY_PARAMS
Constructor and Description |
---|
Translog() |
Modifier and Type | Method and Description |
---|---|
void |
decrementRecoveredOperations(int ops) |
void |
incrementRecoveredOperations() |
void |
readFrom(StreamInput in)
Set this object's fields from a StreamInput.
|
int |
recoveredOperations()
returns the total number of translog operations recovered so far
|
float |
recoveredPercent() |
void |
reset() |
int |
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) |
XContentBuilder |
toXContent(XContentBuilder builder,
ToXContent.Params params) |
void |
writeTo(StreamOutput out)
Write this object's fields to a StreamOutput.
|
start, startTime, stop, stopTime, time
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isFragment
public static final int UNKNOWN
public void reset()
reset
in class RecoveryState.Timer
public void incrementRecoveredOperations()
public void decrementRecoveredOperations(int ops)
public int recoveredOperations()
public int totalOperations()
A value of -1 (UNKNOWN
is return if this is unknown (typically a gateway recovery)
public void totalOperations(int total)
public int totalOperationsOnStart()
totalOperations()
this does change during recovery.
A value of -1 (UNKNOWN
is return if this is unknown (typically a gateway recovery)
public void totalOperationsOnStart(int total)
public float recoveredPercent()
public void readFrom(StreamInput in) throws java.io.IOException
Streamable
readFrom
in interface Streamable
readFrom
in class RecoveryState.Timer
java.io.IOException
public void writeTo(StreamOutput out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
writeTo
in class RecoveryState.Timer
java.io.IOException
public XContentBuilder toXContent(XContentBuilder builder, ToXContent.Params params) throws java.io.IOException
toXContent
in interface ToXContent
java.io.IOException