Package org.elasticsearch.cluster.service

Class TaskBatcher.BatchedTask

java.lang.Object

org.elasticsearch.common.util.concurrent.PrioritizedRunnable

org.elasticsearch.cluster.service.SourcePrioritizedRunnable

org.elasticsearch.cluster.service.TaskBatcher.BatchedTask

All Implemented Interfaces:

Comparable<PrioritizedRunnable>, Runnable

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 final Object	batchingKey	the object that is used as batching key
protected final AtomicBoolean	processed	whether the task has been processed already
protected final Object	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, String source, Object batchingKey, Object task)

Method Summary

Modifier and Type	Method	Description
abstract String	describeTasks(List<? extends TaskBatcher.BatchedTask> tasks)
Object	getTask()
void	run()
String	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.Object

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

Field Details

processed

protected final AtomicBoolean processed

whether the task has been processed already

batchingKey

protected final Object batchingKey

the object that is used as batching key

task

protected final Object task

the task object that is wrapped

Constructor Details

BatchedTask

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

Method Details

run

public void run()

toString

public String toString()

Overrides:

toString in class SourcePrioritizedRunnable

describeTasks

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

getTask

public Object getTask()