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.