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, IndexerDBCoordinator indexerDBCoordinator, com.metamx.emitter.service.ServiceEmitter emitter)

Method Summary

Methods

Modifier and Type	Method and Description
com.metamx.emitter.service.ServiceEmitter	getEmitter()
IndexerDBCoordinator	getIndexerDBCoordinator()
TaskLockbox	getTaskLockbox()
boolean	segmentsAreFromSamePartitionSet(Set<io.druid.timeline.DataSegment> segments)
boolean	taskLockCoversSegments(Task task, Set<io.druid.timeline.DataSegment> segments, boolean allowOlderVersions)
void	verifyTaskLocksAndSinglePartitionSettitude(Task task, Set<io.druid.timeline.DataSegment> segments, boolean allowOlderVersions)

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,
                        IndexerDBCoordinator indexerDBCoordinator,
                        com.metamx.emitter.service.ServiceEmitter emitter)

Method Detail

getTaskLockbox

public TaskLockbox getTaskLockbox()

getIndexerDBCoordinator

public IndexerDBCoordinator getIndexerDBCoordinator()

getEmitter

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

segmentsAreFromSamePartitionSet

public boolean segmentsAreFromSamePartitionSet(Set<io.druid.timeline.DataSegment> segments)

verifyTaskLocksAndSinglePartitionSettitude

public void verifyTaskLocksAndSinglePartitionSettitude(Task task,
                                              Set<io.druid.timeline.DataSegment> segments,
                                              boolean allowOlderVersions)

taskLockCoversSegments

public boolean taskLockCoversSegments(Task task,
                             Set<io.druid.timeline.DataSegment> segments,
                             boolean allowOlderVersions)