public class ReefClientSideHandlers
extends java.lang.Object
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 and Description |
---|
ReefClientSideHandlers(java.lang.String topologyName) |
Modifier and Type | Method and Description |
---|---|
boolean |
waitForSchedulerJobResponse()
Wait indefinitely to receive events from driver
|