Package org.elasticsearch.cluster.service

Class TaskBatcher.BatchedTask

org.elasticsearch.common.util.concurrent.PrioritizedRunnable

org.elasticsearch.cluster.service.SourcePrioritizedRunnable

org.elasticsearch.cluster.service.TaskBatcher.BatchedTask

All Implemented Interfaces:

<

Enclosing class:

TaskBatcher

protected abstract class TaskBatcher.BatchedTask
extends SourcePrioritizedRunnable

Represents a runnable task that supports batching. Implementors of TaskBatcher can subclass this to add a payload to the task.

Field Summary

Fields

Modifier and Type	Field	Description
protected	batchingKey	the object that is used as batching key
protected	processed	whether the task has been processed already
protected	task	the task object that is wrapped

Fields inherited from class org.elasticsearch.cluster.service.SourcePrioritizedRunnable

source

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BatchedTask(Priority priority, source, batchingKey, task)

Method Summary

Modifier and Type	Method	Description
abstract	<? extends TaskBatcher.BatchedTask> tasks)
	getTask()
void	run()
	toString()

Methods inherited from class org.elasticsearch.cluster.service.SourcePrioritizedRunnable

source

Methods inherited from class org.elasticsearch.common.util.concurrent.PrioritizedRunnable

compareTo, getAgeInMillis, getCreationDateInNanos, priority, wrap

Methods inherited from class java.lang.

, , , , , , , , ,

Field Details

processed

protected final  processed

whether the task has been processed already

batchingKey

protected final  batchingKey

the object that is used as batching key

task

protected final  task

the task object that is wrapped

Constructor Details

BatchedTask

protected BatchedTask(Priority priority,
  source,
  batchingKey,
  task)

Method Details

run

public void run()

toString

public  toString()

Overrides:

toString in class SourcePrioritizedRunnable

describeTasks

public abstract  describeTasks(<? extends TaskBatcher.BatchedTask> tasks)

getTask

public  getTask()