io.druid.indexing.overlord

Class CriticalAction<T>

java.lang.Object

io.druid.indexing.overlord.CriticalAction<T>

public class CriticalAction<T>
extends Object

This class represents a critical action must be done while the task's lock is guaranteed to not be revoked in the middle of the action. Implementations must not change the lock state by calling TaskLockbox.lock(TaskLockType, Task, Interval), TaskLockbox.lock(TaskLockType, Task, Interval, long), TaskLockbox.tryLock(TaskLockType, Task, Interval), or TaskLockbox.unlock(Task, Interval). Also, implementations should be finished as soon as possible because all methods in TaskLockbox are blocked until this action is finished.

See Also:

TaskLockbox.doInCriticalSection(io.druid.indexing.common.task.Task, java.util.List<org.joda.time.Interval>, io.druid.indexing.overlord.CriticalAction<T>)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CriticalAction.Action<T>
static class	CriticalAction.Builder<T>

Method Summary

Modifier and Type	Method and Description
static <T> CriticalAction.Builder<T>	builder()

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static <T> CriticalAction.Builder<T> builder()