Package org.elasticsearch.index.shard

Class PrimaryReplicaSyncer.ResyncTask

java.lang.Object

org.elasticsearch.tasks.Task

org.elasticsearch.index.shard.PrimaryReplicaSyncer.ResyncTask

Enclosing class:

PrimaryReplicaSyncer

public static class PrimaryReplicaSyncer.ResyncTask
extends Task

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PrimaryReplicaSyncer.ResyncTask.Status

Field Summary

Fields inherited from class org.elasticsearch.tasks.Task

HEADERS_TO_COPY, TRACE_ID, TRACE_PARENT_HTTP_HEADER, X_ELASTIC_PRODUCT_ORIGIN_HTTP_HEADER, X_OPAQUE_ID_HTTP_HEADER

Constructor Summary

Constructors

Constructor	Description
ResyncTask(long id, String type, String action, String description, TaskId parentTaskId, Map<String,String> headers)

Method Summary

Modifier and Type	Method	Description
String	getPhase()	Get the current phase of the task.
int	getResyncedOperations()	number of operations that have been successfully replicated
int	getSkippedOperations()	number of translog operations that have been skipped
PrimaryReplicaSyncer.ResyncTask.Status	getStatus()	Build a status for this task or null if this task doesn't have status.
int	getTotalOperations()	total number of translog operations that were captured by translog snapshot
void	setPhase(String phase)	Set the current phase of the task.
void	setResyncedOperations(int resyncedOperations)
void	setSkippedOperations(int skippedOperations)
void	setTotalOperations(int totalOperations)

Methods inherited from class org.elasticsearch.tasks.Task

getAction, getDescription, getHeader, getId, getParentTaskId, getStartTime, getStartTimeNanos, getType, headers, result, result, taskInfo, taskInfo

Methods inherited from class java.lang.Object

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

Constructor Details

ResyncTask

public ResyncTask(long id,
 String type,
 String action,
 String description,
 TaskId parentTaskId,
 Map<String,String> headers)

Method Details

setPhase

public void setPhase(String phase)

Set the current phase of the task.

getPhase

public String getPhase()

Get the current phase of the task.

getTotalOperations

public int getTotalOperations()

total number of translog operations that were captured by translog snapshot

setTotalOperations

public void setTotalOperations(int totalOperations)

getResyncedOperations

public int getResyncedOperations()

number of operations that have been successfully replicated

setResyncedOperations

public void setResyncedOperations(int resyncedOperations)

getSkippedOperations

public int getSkippedOperations()

number of translog operations that have been skipped

setSkippedOperations

public void setSkippedOperations(int skippedOperations)

getStatus

public PrimaryReplicaSyncer.ResyncTask.Status getStatus()

Description copied from class: Task

Build a status for this task or null if this task doesn't have status. Since most tasks don't have status this defaults to returning null. While this can never perform IO it might be a costly operation, requiring collating lists of results, etc. So only use it if you need the value.

Overrides:

getStatus in class Task