com.twitter.heron.scheduler.yarn

Class ReefClientSideHandlers

java.lang.Object

com.twitter.heron.scheduler.yarn.ReefClientSideHandlers

public class ReefClientSideHandlers
extends java.lang.Object

Contains client-side listeners for YARN scheduler events emitted by REEF.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ReefClientSideHandlers.FailedJobHandler Handle topology driver failure event
class	ReefClientSideHandlers.RunningJobHandler Job driver notifies us that the job is running.
class	ReefClientSideHandlers.RuntimeErrorHandler Handle an error in the in starting driver for topology.

Constructor Summary

Constructors

Constructor and Description
ReefClientSideHandlers(java.lang.String topologyName)

Method Summary

Modifier and Type	Method and Description
boolean	waitForSchedulerJobResponse() Wait indefinitely to receive events from driver

Methods inherited from class java.lang.Object

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

Constructor Detail

ReefClientSideHandlers

@Inject
public ReefClientSideHandlers(java.lang.String topologyName)

Method Detail

waitForSchedulerJobResponse

public boolean waitForSchedulerJobResponse()
                                    throws java.lang.InterruptedException

Wait indefinitely to receive events from driver

Throws:

java.lang.InterruptedException