org.apache.reef.runtime.local.process

Class ReefRunnableProcessObserver

java.lang.Object

org.apache.reef.runtime.local.process.ReefRunnableProcessObserver

All Implemented Interfaces:

RunnableProcessObserver

@ThreadSafe
public final class ReefRunnableProcessObserver
extends Object
implements RunnableProcessObserver

a RunnableProcessObserver that relies events to REEF's ResourceStatusHandler

Constructor Summary

Constructors

Constructor and Description
ReefRunnableProcessObserver(EventHandler<DriverRuntimeProtocol.ResourceStatusProto> resourceStatusHandler, InjectionFuture<ResourceManager> resourceManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	onProcessExit(String processId, int exitCode) This will be called right after the process exited.
void	onProcessStarted(String processId) This will be called right after the process is launched.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReefRunnableProcessObserver

@Inject
public ReefRunnableProcessObserver(EventHandler<DriverRuntimeProtocol.ResourceStatusProto> resourceStatusHandler,
                                  InjectionFuture<ResourceManager> resourceManager)

Parameters:

resourceStatusHandler - the event handler to inform of resource changes.

Method Detail

onProcessStarted

public void onProcessStarted(String processId)

Description copied from interface: RunnableProcessObserver

This will be called right after the process is launched.

Specified by:

onProcessStarted in interface RunnableProcessObserver

Parameters:

processId - the id of the process that started.

onProcessExit

public void onProcessExit(String processId,
                 int exitCode)

Description copied from interface: RunnableProcessObserver

This will be called right after the process exited.

Specified by:

onProcessExit in interface RunnableProcessObserver

Parameters:

processId - the id of the process that exited.

exitCode - the return code of the process.