public class Tasks extends Object
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 and Description |
---|
Tasks() |
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) |
public static final int DEFAULT_REALTIME_TASK_PRIORITY
public static final int DEFAULT_BATCH_INDEX_TASK_PRIORITY
public static final int DEFAULT_MERGE_TASK_PRIORITY
public static final int DEFAULT_TASK_PRIORITY
public static final long DEFAULT_LOCK_TIMEOUT
public static final String PRIORITY_KEY
public static final String LOCK_TIMEOUT_KEY
public static Map<org.joda.time.Interval,TaskLock> tryAcquireExclusiveLocks(TaskActionClient client, SortedSet<org.joda.time.Interval> intervals) throws IOException
IOException
Copyright © 2011–2018. All rights reserved.