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)

Method Summary

Methods

Modifier and Type	Method and Description
com.metamx.emitter.service.ServiceEmitter	getEmitter()
IndexerMetadataStorageCoordinator	getIndexerMetadataStorageCoordinator()
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,
                        IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
                        com.metamx.emitter.service.ServiceEmitter emitter)

Method Detail

getTaskLockbox

public TaskLockbox getTaskLockbox()

getIndexerMetadataStorageCoordinator

public IndexerMetadataStorageCoordinator getIndexerMetadataStorageCoordinator()

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)