org.apache.samza.rest.proxy.task

Interface TaskProxy

All Known Implementing Classes:

SamzaTaskProxy

public interface TaskProxy

TaskProxy is the primary abstraction that will be used by Rest API's to interact with tasks.

Method Summary

Modifier and Type	Method and Description
java.util.List<Task>	getTasks(JobInstance jobInstance)

Method Detail

getTasks

java.util.List<Task> getTasks(JobInstance jobInstance)
                       throws java.io.IOException,
                              java.lang.InterruptedException

Parameters:

jobInstance - the job instance to get the tasks for.

Returns:

a list of all the Task tasks that belongs to the JobInstance. Each task will have a preferred host and stream partitions assigned to it by the samza job coordinator.

Throws:

java.io.IOException - if there was a problem executing the command to get the tasks.

java.lang.InterruptedException - if the thread was interrupted while waiting for the result.