io.druid.indexing.common.task

Class Tasks

java.lang.Object

io.druid.indexing.common.task.Tasks

public class Tasks
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BATCH_INDEX_TASK_PRIORITY
static long	DEFAULT_LOCK_TIMEOUT
static int	DEFAULT_MERGE_TASK_PRIORITY
static int	DEFAULT_REALTIME_TASK_PRIORITY
static int	DEFAULT_TASK_PRIORITY
static String	LOCK_TIMEOUT_KEY
static String	PRIORITY_KEY

Constructor Summary

Constructors

Constructor and Description
Tasks()

Method Summary

Modifier and Type	Method and Description
static SortedSet<org.joda.time.Interval>	computeCompactIntervals(SortedSet<org.joda.time.Interval> intervals)
static Map<org.joda.time.Interval,TaskLock>	tryAcquireExclusiveLocks(TaskActionClient client, SortedSet<org.joda.time.Interval> intervals)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_REALTIME_TASK_PRIORITY

public static final int DEFAULT_REALTIME_TASK_PRIORITY

See Also:

Constant Field Values

DEFAULT_BATCH_INDEX_TASK_PRIORITY

public static final int DEFAULT_BATCH_INDEX_TASK_PRIORITY

See Also:

Constant Field Values

DEFAULT_MERGE_TASK_PRIORITY

public static final int DEFAULT_MERGE_TASK_PRIORITY

See Also:

Constant Field Values

DEFAULT_TASK_PRIORITY

public static final int DEFAULT_TASK_PRIORITY

See Also:

Constant Field Values

DEFAULT_LOCK_TIMEOUT

public static final long DEFAULT_LOCK_TIMEOUT

See Also:

Constant Field Values

PRIORITY_KEY

public static final String PRIORITY_KEY

See Also:

Constant Field Values

LOCK_TIMEOUT_KEY

public static final String LOCK_TIMEOUT_KEY

See Also:

Constant Field Values

Constructor Detail

Tasks

public Tasks()

Method Detail

tryAcquireExclusiveLocks

public static Map<org.joda.time.Interval,TaskLock> tryAcquireExclusiveLocks(TaskActionClient client,
                                                                            SortedSet<org.joda.time.Interval> intervals)
                                                                     throws IOException

Throws:

IOException

computeCompactIntervals

public static SortedSet<org.joda.time.Interval> computeCompactIntervals(SortedSet<org.joda.time.Interval> intervals)