Modifier and Type | Method and Description |
---|---|
TaskToolbox |
TaskToolboxFactory.build(Task task) |
Constructor and Description |
---|
TaskToolbox(TaskConfig config,
Task task,
TaskActionClient taskActionClient,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
Modifier and Type | Method and Description |
---|---|
Task |
TaskActionHolder.getTask() |
Modifier and Type | Method and Description |
---|---|
TaskActionClient |
TaskActionClientFactory.create(Task task) |
TaskActionClient |
RemoteTaskActionClientFactory.create(Task task) |
TaskActionClient |
LocalTaskActionClientFactory.create(Task task) |
RetType |
TaskAction.perform(Task task,
TaskActionToolbox toolbox) |
SegmentPublishResult |
SegmentTransactionalInsertAction.perform(Task task,
TaskActionToolbox toolbox)
|
Void |
SegmentNukeAction.perform(Task task,
TaskActionToolbox toolbox) |
Void |
SegmentMetadataUpdateAction.perform(Task task,
TaskActionToolbox toolbox) |
List<DataSegment> |
SegmentListUsedAction.perform(Task task,
TaskActionToolbox toolbox) |
List<DataSegment> |
SegmentListUnusedAction.perform(Task task,
TaskActionToolbox toolbox) |
Set<DataSegment> |
SegmentInsertAction.perform(Task task,
TaskActionToolbox toolbox)
Behaves similarly to
IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set, DataSourceMetadata, DataSourceMetadata) ,
with startMetadata and endMetadata both null. |
SegmentIdentifier |
SegmentAllocateAction.perform(Task task,
TaskActionToolbox toolbox) |
Boolean |
ResetDataSourceMetadataAction.perform(Task task,
TaskActionToolbox toolbox) |
TaskLock |
LockTryAcquireAction.perform(Task task,
TaskActionToolbox toolbox) |
Void |
LockReleaseAction.perform(Task task,
TaskActionToolbox toolbox) |
List<TaskLock> |
LockListAction.perform(Task task,
TaskActionToolbox toolbox) |
TaskLock |
LockAcquireAction.perform(Task task,
TaskActionToolbox toolbox) |
boolean |
TaskActionToolbox.taskLockCoversSegments(Task task,
Set<DataSegment> segments) |
void |
TaskActionToolbox.verifyTaskLocks(Task task,
Set<DataSegment> segments) |
Constructor and Description |
---|
LocalTaskActionClient(Task task,
TaskStorage storage,
TaskActionToolbox toolbox) |
RemoteTaskActionClient(Task task,
com.metamx.http.client.HttpClient httpClient,
ServerDiscoverySelector selector,
RetryPolicyFactory retryPolicyFactory,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
TaskActionHolder(Task task,
TaskAction action) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFixedIntervalTask |
class |
AbstractTask |
class |
AppendTask |
class |
ArchiveTask |
class |
ConvertSegmentBackwardsCompatibleTask
Deprecated.
|
static class |
ConvertSegmentBackwardsCompatibleTask.SubTask
Deprecated.
|
class |
ConvertSegmentTask
This task takes a segment and attempts to reindex it in the latest version with the specified indexSpec.
|
static class |
ConvertSegmentTask.SubTask |
class |
HadoopConverterTask |
static class |
HadoopConverterTask.ConverterSubTask |
class |
HadoopIndexTask |
class |
HadoopTask |
class |
IndexTask |
class |
KillTask |
class |
MergeTask |
class |
MergeTaskBase |
class |
MoveTask |
class |
NoopTask |
class |
RealtimeIndexTask |
class |
RestoreTask |
Modifier and Type | Method and Description |
---|---|
protected Iterable<Task> |
HadoopConverterTask.generateSubTasks(String groupId,
Iterable<DataSegment> segments,
IndexSpec indexSpec,
boolean force,
boolean validate,
Map<String,Object> context) |
protected Iterable<Task> |
ConvertSegmentTask.generateSubTasks(String groupId,
Iterable<DataSegment> segments,
IndexSpec indexSpec,
boolean force,
boolean validate,
Map<String,Object> context) |
Constructor and Description |
---|
TaskActionSegmentPublisher(Task task,
TaskToolbox taskToolbox) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaIndexTask |
Modifier and Type | Method and Description |
---|---|
List<Task> |
TaskStorageQueryAdapter.getActiveTasks() |
List<Task> |
TaskStorage.getActiveTasks()
Returns a list of currently running or pending tasks as stored in the storage facility.
|
List<Task> |
MetadataTaskStorage.getActiveTasks() |
List<Task> |
HeapMemoryTaskStorage.getActiveTasks() |
Collection<Task> |
WorkerTaskRunner.getPendingTaskPayloads() |
Collection<Task> |
RemoteTaskRunner.getPendingTaskPayloads() |
com.google.common.base.Optional<Task> |
TaskStorageQueryAdapter.getTask(String taskid) |
com.google.common.base.Optional<Task> |
TaskStorage.getTask(String taskid)
Returns task as stored in the storage facility.
|
com.google.common.base.Optional<Task> |
MetadataTaskStorage.getTask(String taskId) |
com.google.common.base.Optional<Task> |
HeapMemoryTaskStorage.getTask(String taskid) |
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>> |
ThreadPoolTaskRunner.restore() |
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>> |
TaskRunner.restore()
Some task runners can restart previously-running tasks after being bounced.
|
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>> |
RemoteTaskRunner.restore() |
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>> |
ForkingTaskRunner.restore() |
Modifier and Type | Method and Description |
---|---|
boolean |
TaskQueue.add(Task task)
Adds some work to the queue and the underlying task storage facility with a generic "running" status.
|
void |
TaskLockbox.add(Task task) |
<T> void |
TaskStorage.addAuditLog(Task task,
TaskAction<T> taskAction)
Add an action taken by a task to the audit log.
|
<T> void |
MetadataTaskStorage.addAuditLog(Task task,
TaskAction<T> taskAction) |
<T> void |
HeapMemoryTaskStorage.addAuditLog(Task task,
TaskAction<T> taskAction) |
boolean |
ImmutableWorkerInfo.canRunTask(Task task) |
List<TaskLock> |
TaskLockbox.findLocksForTask(Task task)
Return the currently-active locks for some task.
|
com.google.common.base.Optional<TaskActionClient> |
TaskMaster.getTaskActionClient(Task task) |
void |
TaskStorage.insert(Task task,
TaskStatus status)
Adds a task to the storage facility with a particular status.
|
void |
MetadataTaskStorage.insert(Task task,
TaskStatus status) |
void |
HeapMemoryTaskStorage.insert(Task task,
TaskStatus status) |
TaskLock |
TaskLockbox.lock(Task task,
org.joda.time.Interval interval)
Acquires a lock on behalf of a task.
|
void |
TaskLockbox.remove(Task task)
Release all locks for a task and remove task from set of active tasks.
|
com.google.common.util.concurrent.ListenableFuture<TaskStatus> |
ThreadPoolTaskRunner.run(Task task) |
com.google.common.util.concurrent.ListenableFuture<TaskStatus> |
TaskRunner.run(Task task)
Run a task.
|
com.google.common.util.concurrent.ListenableFuture<TaskStatus> |
RemoteTaskRunner.run(Task task)
A task will be run only if there is no current knowledge in the RemoteTaskRunner of the task.
|
com.google.common.util.concurrent.ListenableFuture<TaskStatus> |
ForkingTaskRunner.run(Task task) |
com.google.common.base.Optional<TaskLock> |
TaskLockbox.tryLock(Task task,
org.joda.time.Interval interval)
Attempt to lock a task, without removing it from the queue.
|
void |
TaskLockbox.unlock(Task task,
org.joda.time.Interval interval)
Release lock held for a task on a particular interval.
|
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
OverlordResource.taskPost(Task task,
javax.servlet.http.HttpServletRequest req) |
Modifier and Type | Method and Description |
---|---|
String |
JavaScriptWorkerSelectStrategy.SelectorFunction.apply(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
com.google.common.base.Optional<ImmutableWorkerInfo> |
WorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task)
Customizable logic for selecting a worker to run a task.
|
com.google.common.base.Optional<ImmutableWorkerInfo> |
JavaScriptWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
com.google.common.base.Optional<ImmutableWorkerInfo> |
FillCapacityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
com.google.common.base.Optional<ImmutableWorkerInfo> |
FillCapacityWithAffinityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
com.google.common.base.Optional<ImmutableWorkerInfo> |
EqualDistributionWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config,
com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers,
Task task) |
Modifier and Type | Method and Description |
---|---|
static TaskAnnouncement |
TaskAnnouncement.create(Task task,
TaskStatus status,
TaskLocation location) |
Modifier and Type | Method and Description |
---|---|
String |
OverlordResourceTestClient.submitTask(Task task) |
Copyright © 2011–2017. All rights reserved.