| Package | Description | 
|---|---|
| io.druid.indexing.common | |
| io.druid.indexing.common.actions | |
| io.druid.indexing.overlord | 
| Modifier and Type | Method and Description | 
|---|---|
TaskLockType | 
TaskLock.getType()  | 
static TaskLockType | 
TaskLockType.valueOf(String name)
Returns the enum constant of this type with the specified name. 
 | 
static TaskLockType[] | 
TaskLockType.values()
Returns an array containing the constants of this enum type, in
the order they are declared. 
 | 
| Constructor and Description | 
|---|
TaskLock(TaskLockType type,
        String groupId,
        String dataSource,
        org.joda.time.Interval interval,
        String version,
        int priority)  | 
TaskLock(TaskLockType type,
        String groupId,
        String dataSource,
        org.joda.time.Interval interval,
        String version,
        int priority,
        boolean revoked)  | 
| Modifier and Type | Method and Description | 
|---|---|
TaskLockType | 
LockTryAcquireAction.getType()  | 
TaskLockType | 
LockAcquireAction.getType()  | 
| Constructor and Description | 
|---|
LockAcquireAction(TaskLockType type,
                 org.joda.time.Interval interval,
                 long timeoutMs)  | 
LockTryAcquireAction(TaskLockType type,
                    org.joda.time.Interval interval)  | 
| Modifier and Type | Method and Description | 
|---|---|
LockResult | 
TaskLockbox.lock(TaskLockType lockType,
    Task task,
    org.joda.time.Interval interval)
Acquires a lock on behalf of a task. 
 | 
LockResult | 
TaskLockbox.lock(TaskLockType lockType,
    Task task,
    org.joda.time.Interval interval,
    long timeoutMs)
Acquires a lock on behalf of a task, waiting up to the specified wait time if necessary. 
 | 
LockResult | 
TaskLockbox.tryLock(TaskLockType lockType,
       Task task,
       org.joda.time.Interval interval)
Attempt to acquire a lock for a task, without removing it from the queue. 
 | 
Copyright © 2011–2018. All rights reserved.