io.druid.indexing.common.task

Class TaskResource

java.lang.Object

io.druid.indexing.common.task.TaskResource

public class TaskResource
extends Object

Constructor Summary

Constructors

Constructor and Description
TaskResource(String availabilityGroup, int requiredCapacity)

Method Summary

Methods

Modifier and Type	Method and Description
String	getAvailabilityGroup() Returns availability group ID of this task.
int	getRequiredCapacity()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskResource

public TaskResource(String availabilityGroup,
            int requiredCapacity)

Method Detail

getAvailabilityGroup

public String getAvailabilityGroup()

Returns availability group ID of this task. Tasks the same availability group cannot be assigned to the same worker. If tasks do not have this restriction, a common convention is to set the availability group ID to the task ID.

Returns:

task availability group

getRequiredCapacity

public int getRequiredCapacity()

Returns:

the number of worker slots this task will take

toString

public String toString()

Overrides:

toString in class Object