org.apache.reef.runtime.common.driver.client

Class LoggingJobStatusHandler

java.lang.Object

org.apache.reef.runtime.common.driver.client.LoggingJobStatusHandler

All Implemented Interfaces:

JobStatusHandler, EventHandler<ReefServiceProtos.JobStatusProto>

public class LoggingJobStatusHandler
extends Object
implements JobStatusHandler

A handler for job status messages that just logs them.

Method Summary

Methods

Modifier and Type	Method and Description
ReefServiceProtos.JobStatusProto	getLastStatus() Return the last known status of the REEF job.
void	onNext(ReefServiceProtos.JobStatusProto jobStatusProto) Handles an event.

Methods inherited from class java.lang.Object

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

Method Detail

onNext

public void onNext(ReefServiceProtos.JobStatusProto jobStatusProto)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<ReefServiceProtos.JobStatusProto>

Parameters:

jobStatusProto - an event

getLastStatus

public ReefServiceProtos.JobStatusProto getLastStatus()

Return the last known status of the REEF job. Can return null if the job has not been launched yet.

Specified by:

getLastStatus in interface JobStatusHandler

Returns:

Last status of the REEF job.