public class TaskActionToolbox extends Object
Constructor and Description |
---|
TaskActionToolbox(TaskLockbox taskLockbox,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
com.metamx.emitter.service.ServiceEmitter emitter) |
Modifier and Type | Method and Description |
---|---|
com.metamx.emitter.service.ServiceEmitter |
getEmitter() |
IndexerMetadataStorageCoordinator |
getIndexerMetadataStorageCoordinator() |
TaskLockbox |
getTaskLockbox() |
boolean |
taskLockCoversSegments(Task task,
Set<io.druid.timeline.DataSegment> segments) |
void |
verifyTaskLocks(Task task,
Set<io.druid.timeline.DataSegment> segments) |
@Inject public TaskActionToolbox(TaskLockbox taskLockbox, IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator, com.metamx.emitter.service.ServiceEmitter emitter)
public TaskLockbox getTaskLockbox()
public IndexerMetadataStorageCoordinator getIndexerMetadataStorageCoordinator()
public com.metamx.emitter.service.ServiceEmitter getEmitter()
Copyright © 2011–2016. All rights reserved.