io.druid.indexing.common.actions

Class TaskActionToolbox

java.lang.Object

io.druid.indexing.common.actions.TaskActionToolbox

public class TaskActionToolbox
extends Object

Constructor Summary

Constructors

Constructor and Description
TaskActionToolbox(TaskLockbox taskLockbox, IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator, com.metamx.emitter.service.ServiceEmitter emitter, SupervisorManager supervisorManager)

Method Summary

Modifier and Type	Method and Description
com.metamx.emitter.service.ServiceEmitter	getEmitter()
IndexerMetadataStorageCoordinator	getIndexerMetadataStorageCoordinator()
SupervisorManager	getSupervisorManager()
TaskLockbox	getTaskLockbox()
boolean	taskLockCoversSegments(Task task, Set<DataSegment> segments)
void	verifyTaskLocks(Task task, Set<DataSegment> segments)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskActionToolbox

@Inject
public TaskActionToolbox(TaskLockbox taskLockbox,
                                 IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
                                 com.metamx.emitter.service.ServiceEmitter emitter,
                                 SupervisorManager supervisorManager)

Method Detail

getTaskLockbox

public TaskLockbox getTaskLockbox()

getIndexerMetadataStorageCoordinator

public IndexerMetadataStorageCoordinator getIndexerMetadataStorageCoordinator()

getEmitter

public com.metamx.emitter.service.ServiceEmitter getEmitter()

getSupervisorManager

public SupervisorManager getSupervisorManager()

verifyTaskLocks

public void verifyTaskLocks(Task task,
                            Set<DataSegment> segments)

taskLockCoversSegments

public boolean taskLockCoversSegments(Task task,
                                      Set<DataSegment> segments)