org.elasticsearch.index.reindex

Class WorkingBulkByScrollTask

java.lang.Object

org.elasticsearch.tasks.Task

org.elasticsearch.tasks.CancellableTask

org.elasticsearch.index.reindex.BulkByScrollTask

org.elasticsearch.index.reindex.WorkingBulkByScrollTask

All Implemented Interfaces:

SuccessfullyProcessed

public class WorkingBulkByScrollTask
extends BulkByScrollTask
implements SuccessfullyProcessed

BulkByScrollTask subclass for tasks that actually perform the work. Compare to ParentBulkByScrollTask.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.index.reindex.BulkByScrollTask

BulkByScrollTask.Status, BulkByScrollTask.StatusOrException

Constructor Summary

Constructors

Constructor and Description
WorkingBulkByScrollTask(long id, java.lang.String type, java.lang.String action, java.lang.String description, TaskId parentTask, java.lang.Integer sliceId, float requestsPerSecond)

Method Summary

Modifier and Type	Method and Description
void	countBatch()
void	countBulkRetry()
void	countCreated()
void	countDeleted()
void	countNoop()
void	countSearchRetry()
void	countUpdated()
void	countVersionConflict()
void	delayPrepareBulkRequest(ThreadPool threadPool, TimeValue lastBatchStartTime, int lastBatchSize, AbstractRunnable prepareBulkRequestRunnable) Schedule prepareBulkRequestRunnable to run after some delay.
long	getCreated() Count of documents created.
long	getDeleted() Count of successful delete operations.
TaskInfo	getInfoGivenSliceInfo(java.lang.String localNodeId, java.util.List<TaskInfo> sliceInfo) Build the status for this task given a snapshot of the information of running slices.
BulkByScrollTask.Status	getStatus() Build a status for this task or null if this task doesn't have status.
long	getUpdated() Count of documents updated.
protected void	onCancelled() Called after the task is cancelled so that it can take any actions that it has to take.
void	rethrottle(float newRequestsPerSecond) Apply the newRequestsPerSecond.
int	runningSliceSubTasks() The number of sub-slices that are still running.
void	setTotal(long totalHits)
TimeValue	throttleWaitTime(TimeValue lastBatchStartTime, TimeValue now, int lastBatchSize)

Methods inherited from class org.elasticsearch.index.reindex.BulkByScrollTask

shouldCancelChildrenOnCancellation

Methods inherited from class org.elasticsearch.tasks.CancellableTask

cancelOnParentLeaving, getReasonCancelled, isCancelled

Methods inherited from class org.elasticsearch.tasks.Task

getAction, getDescription, getId, getParentTaskId, getStartTime, getType, result, result, taskInfo, taskInfo

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.index.reindex.SuccessfullyProcessed

getSuccessfullyProcessed

Constructor Detail

WorkingBulkByScrollTask

public WorkingBulkByScrollTask(long id,
                               java.lang.String type,
                               java.lang.String action,
                               java.lang.String description,
                               TaskId parentTask,
                               java.lang.Integer sliceId,
                               float requestsPerSecond)

Method Detail

getStatus

public BulkByScrollTask.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.

Specified by:

getStatus in class BulkByScrollTask

onCancelled

protected void onCancelled()

Description copied from class: CancellableTask

Called after the task is cancelled so that it can take any actions that it has to take.

Overrides:

onCancelled in class CancellableTask

runningSliceSubTasks

public int runningSliceSubTasks()

Description copied from class: BulkByScrollTask

The number of sub-slices that are still running. WorkingBulkByScrollTask will always have 0 and ParentBulkByScrollTask will return the number of waiting tasks. Used to decide how to perform rethrottling.

Specified by:

runningSliceSubTasks in class BulkByScrollTask

getInfoGivenSliceInfo

public TaskInfo getInfoGivenSliceInfo(java.lang.String localNodeId,
                                      java.util.List<TaskInfo> sliceInfo)

Description copied from class: BulkByScrollTask

Build the status for this task given a snapshot of the information of running slices.

Specified by:

getInfoGivenSliceInfo in class BulkByScrollTask

setTotal

public void setTotal(long totalHits)

countBatch

public void countBatch()

countNoop

public void countNoop()

getCreated

public long getCreated()

Description copied from interface: SuccessfullyProcessed

Count of documents created.

Specified by:

getCreated in interface SuccessfullyProcessed

countCreated

public void countCreated()

getUpdated

public long getUpdated()

Description copied from interface: SuccessfullyProcessed

Count of documents updated.

Specified by:

getUpdated in interface SuccessfullyProcessed

countUpdated

public void countUpdated()

getDeleted

public long getDeleted()

Description copied from interface: SuccessfullyProcessed

Count of successful delete operations.

Specified by:

getDeleted in interface SuccessfullyProcessed

countDeleted

public void countDeleted()

countVersionConflict

public void countVersionConflict()

countBulkRetry

public void countBulkRetry()

countSearchRetry

public void countSearchRetry()

delayPrepareBulkRequest

public void delayPrepareBulkRequest(ThreadPool threadPool,
                                    TimeValue lastBatchStartTime,
                                    int lastBatchSize,
                                    AbstractRunnable prepareBulkRequestRunnable)

Schedule prepareBulkRequestRunnable to run after some delay. This is where throttling plugs into reindexing so the request can be rescheduled over and over again.

throttleWaitTime

public TimeValue throttleWaitTime(TimeValue lastBatchStartTime,
                                  TimeValue now,
                                  int lastBatchSize)

rethrottle

public void rethrottle(float newRequestsPerSecond)

Description copied from class: BulkByScrollTask

Apply the newRequestsPerSecond.

Specified by:

rethrottle in class BulkByScrollTask