Package org.elasticsearch.indices.recovery

Class RecoveryState.Index

java.lang.Object

org.elasticsearch.indices.recovery.RecoveryState.Timer

org.elasticsearch.indices.recovery.RecoveryState.Index

All Implemented Interfaces:

Writeable, ToXContent, ToXContentFragment

Enclosing class:

RecoveryState

public static class RecoveryState.Index
extends RecoveryState.Timer
implements ToXContentFragment, Writeable

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent

ToXContent.DelegatingMapParams, ToXContent.MapParams, 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 long	UNKNOWN

Fields inherited from class org.elasticsearch.indices.recovery.RecoveryState.Timer

startNanoTime, startTime, stopTime, time

Fields inherited from interface org.elasticsearch.common.xcontent.ToXContent

EMPTY_PARAMS

Constructor Summary

Constructors

Constructor	Description
Index()
Index(StreamInput in)

Method Summary

Modifier and Type	Method	Description
void	addFileDetail(java.lang.String name, long length, boolean reused)
void	addRecoveredBytesToFile(java.lang.String name, long bytes)
void	addSourceThrottling(long timeInNanos)
void	addTargetThrottling(long timeInNanos)
java.util.List<RecoveryState.File>	fileDetails()
RecoveryState.File	getFileDetails(java.lang.String dest)
long	recoveredBytes()	total number of bytes recovered so far, including both existing and reused
float	recoveredBytesPercent()	percent of bytes recovered out of total files bytes *to be* recovered
int	recoveredFileCount()	number of file that were recovered (excluding on ongoing files)
float	recoveredFilesPercent()	percent of recovered (i.e., not reused) files out of the total files to be recovered
void	reset()
long	reusedBytes()
int	reusedFileCount()
TimeValue	sourceThrottling()
TimeValue	targetThrottling()
java.lang.String	toString()
long	totalBytes()	total number of bytes in th shard
int	totalFileCount()	total number of files that are part of this recovery, both re-used and recovered
long	totalRecoverBytes()	total bytes of files to be recovered (potentially not yet done)
int	totalRecoverFiles()	total number of files to be recovered (potentially not yet done)
long	totalReuseBytes()
XContentBuilder	toXContent(XContentBuilder builder, ToXContent.Params params)
void	updateVersion(long version)
long	version()
void	writeTo(StreamOutput out)	Write this into the StreamOutput.

Methods inherited from class org.elasticsearch.indices.recovery.RecoveryState.Timer

start, startTime, stop, stopTime, time

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.common.xcontent.ToXContentFragment

isFragment

Field Detail

UNKNOWN

public static final long UNKNOWN

See Also:

Constant Field Values

Constructor Detail

Index

public Index()

Index

public Index(StreamInput in)
      throws java.io.IOException

Throws:

java.io.IOException

Method Detail

writeTo

public void writeTo(StreamOutput out)
             throws java.io.IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Overrides:

writeTo in class RecoveryState.Timer

Throws:

java.io.IOException

fileDetails

public java.util.List<RecoveryState.File> fileDetails()

reset

public void reset()

Overrides:

reset in class RecoveryState.Timer

addFileDetail

public void addFileDetail(java.lang.String name,
                          long length,
                          boolean reused)

addRecoveredBytesToFile

public void addRecoveredBytesToFile(java.lang.String name,
                                    long bytes)

version

public long version()

addSourceThrottling

public void addSourceThrottling(long timeInNanos)

addTargetThrottling

public void addTargetThrottling(long timeInNanos)

sourceThrottling

public TimeValue sourceThrottling()

targetThrottling

public TimeValue targetThrottling()

totalFileCount

public int totalFileCount()

total number of files that are part of this recovery, both re-used and recovered

totalRecoverFiles

public int totalRecoverFiles()

total number of files to be recovered (potentially not yet done)

recoveredFileCount

public int recoveredFileCount()

number of file that were recovered (excluding on ongoing files)

recoveredFilesPercent

public float recoveredFilesPercent()

percent of recovered (i.e., not reused) files out of the total files to be recovered

totalBytes

public long totalBytes()

total number of bytes in th shard

recoveredBytes

public long recoveredBytes()

total number of bytes recovered so far, including both existing and reused

totalRecoverBytes

public long totalRecoverBytes()

total bytes of files to be recovered (potentially not yet done)

totalReuseBytes

public long totalReuseBytes()

recoveredBytesPercent

public float recoveredBytesPercent()

percent of bytes recovered out of total files bytes *to be* recovered

reusedFileCount

public int reusedFileCount()

reusedBytes

public long reusedBytes()

updateVersion

public void updateVersion(long version)

toXContent

public XContentBuilder toXContent(XContentBuilder builder,
                                  ToXContent.Params params)
                           throws java.io.IOException

Specified by:

toXContent in interface ToXContent

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getFileDetails

public RecoveryState.File getFileDetails(java.lang.String dest)