io.druid.indexing.overlord

Class TaskStorageQueryAdapter

java.lang.Object

io.druid.indexing.overlord.TaskStorageQueryAdapter

public class TaskStorageQueryAdapter
extends Object

Wraps a TaskStorage, providing a useful collection of read-only methods.

Constructor Summary

Constructors

Constructor and Description
TaskStorageQueryAdapter(TaskStorage storage)

Method Summary

Methods

Modifier and Type	Method and Description
List<Task>	getActiveTasks()
Set<io.druid.timeline.DataSegment>	getInsertedSegments(String taskid) Returns all segments created by this task.
List<TaskStatus>	getRecentlyFinishedTaskStatuses()
com.google.common.base.Optional<TaskStatus>	getStatus(String taskid)
com.google.common.base.Optional<Task>	getTask(String taskid)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskStorageQueryAdapter

@Inject
public TaskStorageQueryAdapter(TaskStorage storage)

Method Detail

getActiveTasks

public List<Task> getActiveTasks()

getRecentlyFinishedTaskStatuses

public List<TaskStatus> getRecentlyFinishedTaskStatuses()

getTask

public com.google.common.base.Optional<Task> getTask(String taskid)

getStatus

public com.google.common.base.Optional<TaskStatus> getStatus(String taskid)

getInsertedSegments

public Set<io.druid.timeline.DataSegment> getInsertedSegments(String taskid)

Returns all segments created by this task. This method is useful when you want to figure out all of the things a single task spawned. It does pose issues with the result set perhaps growing boundlessly and we do not do anything to protect against that. Use at your own risk and know that at some point, we might adjust this to actually enforce some sort of limits.

Parameters:

taskid - task ID

Returns:

set of segments created by the specified task