io.druid.indexing.overlord.http

Class OverlordResource

java.lang.Object

io.druid.indexing.overlord.http.OverlordResource

public class OverlordResource
extends Object

Constructor Summary

Constructors

Constructor and Description
OverlordResource(TaskMaster taskMaster, TaskStorageQueryAdapter taskStorageQueryAdapter, io.druid.tasklogs.TaskLogStreamer taskLogStreamer, JacksonConfigManager configManager)

Method Summary

Methods

Modifier and Type	Method and Description
<T> javax.ws.rs.core.Response	doAction(TaskActionHolder<T> holder)
javax.ws.rs.core.Response	doGetLog(String taskid, long offset)
javax.ws.rs.core.Response	doIndex(Task task) Deprecated.
javax.ws.rs.core.Response	doMerge(Task task) Deprecated.
javax.ws.rs.core.Response	doShutdown(String taskid)
javax.ws.rs.core.Response	getCompleteTasks()
javax.ws.rs.core.Response	getPendingTasks()
javax.ws.rs.core.Response	getRunningTasks()
javax.ws.rs.core.Response	getScalingState()
javax.ws.rs.core.Response	getTaskPayload(String taskid)
javax.ws.rs.core.Response	getTaskSegments(String taskid)
javax.ws.rs.core.Response	getTaskStatus(String taskid)
javax.ws.rs.core.Response	getWaitingTasks()
javax.ws.rs.core.Response	getWorkerConfig()
javax.ws.rs.core.Response	getWorkers()
javax.ws.rs.core.Response	getWorkerSetupData() Deprecated.
javax.ws.rs.core.Response	setWorkerConfig(WorkerBehaviorConfig workerBehaviorConfig)
javax.ws.rs.core.Response	setWorkerSetupData(WorkerSetupData workerSetupData) Deprecated.
javax.ws.rs.core.Response	taskPost(Task task)

Methods inherited from class java.lang.Object

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

Constructor Detail

OverlordResource

@Inject
public OverlordResource(TaskMaster taskMaster,
                       TaskStorageQueryAdapter taskStorageQueryAdapter,
                       io.druid.tasklogs.TaskLogStreamer taskLogStreamer,
                       JacksonConfigManager configManager)
                 throws Exception

Throws:

Exception

Method Detail

doMerge

@Deprecated
public javax.ws.rs.core.Response doMerge(Task task)

Deprecated.

doIndex

@Deprecated
public javax.ws.rs.core.Response doIndex(Task task)

Deprecated.

taskPost

public javax.ws.rs.core.Response taskPost(Task task)

getTaskPayload

public javax.ws.rs.core.Response getTaskPayload(String taskid)

getTaskStatus

public javax.ws.rs.core.Response getTaskStatus(String taskid)

getTaskSegments

public javax.ws.rs.core.Response getTaskSegments(String taskid)

doShutdown

public javax.ws.rs.core.Response doShutdown(String taskid)

getWorkerConfig

public javax.ws.rs.core.Response getWorkerConfig()

setWorkerConfig

public javax.ws.rs.core.Response setWorkerConfig(WorkerBehaviorConfig workerBehaviorConfig)

getWorkerSetupData

@Deprecated
public javax.ws.rs.core.Response getWorkerSetupData()

Deprecated.

setWorkerSetupData

@Deprecated
public javax.ws.rs.core.Response setWorkerSetupData(WorkerSetupData workerSetupData)

Deprecated.

doAction

public <T> javax.ws.rs.core.Response doAction(TaskActionHolder<T> holder)

getWaitingTasks

public javax.ws.rs.core.Response getWaitingTasks()

getPendingTasks

public javax.ws.rs.core.Response getPendingTasks()

getRunningTasks

public javax.ws.rs.core.Response getRunningTasks()

getCompleteTasks

public javax.ws.rs.core.Response getCompleteTasks()

getWorkers

public javax.ws.rs.core.Response getWorkers()

getScalingState

public javax.ws.rs.core.Response getScalingState()

doGetLog

public javax.ws.rs.core.Response doGetLog(String taskid,
                                 long offset)