org.apache.samza.monitor

Class JobsClient

java.lang.Object

org.apache.samza.monitor.JobsClient

public class JobsClient
extends java.lang.Object

This is a helper class to interact with the samza-rest apis. It contains the functionality to read the tasks associated with a samza job, to get the status of a samza job.

Constructor Summary

Constructors

Constructor and Description
JobsClient(java.util.List<java.lang.String> jobStatusServers)

Method Summary

Modifier and Type	Method and Description
JobStatus	getJobStatus(JobInstance jobInstance) This method should be used to find the JobStatus of a jobInstance.
java.util.List<Task>	getTasks(JobInstance jobInstance) This method retrieves and returns the list of tasks that are associated with a JobInstance.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobsClient

public JobsClient(java.util.List<java.lang.String> jobStatusServers)

Parameters:

jobStatusServers - list of jobStatusServers, where each jobStatusServer is of the form Host:Port

Method Detail

getTasks

public java.util.List<Task> getTasks(JobInstance jobInstance)

This method retrieves and returns the list of tasks that are associated with a JobInstance.

Parameters:

jobInstance - an instance of the samza job.

Returns:

the list of tasks that are associated with the samza job.

Throws:

org.apache.samza.SamzaException - if there were any problems with the http request.

getJobStatus

public JobStatus getJobStatus(JobInstance jobInstance)

This method should be used to find the JobStatus of a jobInstance.

Parameters:

jobInstance - a instance of the job.

Returns:

the job status of the JobInstance.

Throws:

org.apache.samza.SamzaException - if there are any problems with the http request.