java.lang.Object

org.elasticsearch.index.reindex.LeaderBulkByScrollTaskState

public class LeaderBulkByScrollTaskState
extends java.lang.Object

Tracks the state of sliced subtasks and provides unified status information for a sliced BulkByScrollRequest.

Method Summary

Modifier and Type	Method	Description
`int`	`getSlices()`	Returns the number of slices this BulkByScrollRequest will use
`BulkByScrollTask.Status`	`getStatus()`	Get the combined statuses of sliced subtasks
`BulkByScrollTask.Status`	`getStatus(java.util.List<BulkByScrollTask.StatusOrException> statuses)`	Get the combined statuses of slice subtasks, merged with the given list of statuses
`void`	`onSliceFailure(ActionListener<BulkByScrollResponse> listener, int sliceId, java.lang.Exception e)`	Record a failure from a slice and respond to the listener if the request is finished.
`void`	`onSliceResponse(ActionListener<BulkByScrollResponse> listener, int sliceId, BulkByScrollResponse response)`	Record a response from a slice and respond to the listener if the request is finished.
`int`	`runningSliceSubTasks()`	The number of sliced subtasks that are still running

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

Constructor Details
- LeaderBulkByScrollTaskState
  
  public LeaderBulkByScrollTaskState(BulkByScrollTask task, int slices)
Method Details
- getSlices
  
  public int getSlices()
  
  Returns the number of slices this BulkByScrollRequest will use
- getStatus
  
  public BulkByScrollTask.Status getStatus(java.util.List<BulkByScrollTask.StatusOrException> statuses)
  
  Get the combined statuses of slice subtasks, merged with the given list of statuses
- getStatus
  
  public BulkByScrollTask.Status getStatus()
  
  Get the combined statuses of sliced subtasks
- runningSliceSubTasks
  
  public int runningSliceSubTasks()
  
  The number of sliced subtasks that are still running
- onSliceResponse
  
  public void onSliceResponse(ActionListener<BulkByScrollResponse> listener, int sliceId, BulkByScrollResponse response)
  
  Record a response from a slice and respond to the listener if the request is finished.
- onSliceFailure
  
  public void onSliceFailure(ActionListener<BulkByScrollResponse> listener, int sliceId, java.lang.Exception e)
  
  Record a failure from a slice and respond to the listener if the request is finished.

Class LeaderBulkByScrollTaskState