Package | Description |
---|---|
io.druid.indexing.overlord |
Modifier and Type | Method and Description |
---|---|
static LockResult |
LockResult.fail(boolean revoked) |
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.
|
static LockResult |
LockResult.ok(TaskLock taskLock) |
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.