public final class RunningJobImpl extends Object implements RunningJob, EventHandler<ReefServiceProtos.JobStatusProto>
Modifier and Type | Method and Description |
---|---|
void |
close()
Cancels the running Job.
|
void |
close(byte[] message)
Cancels the running Job.
|
String |
getId()
Returns an identifier of this object.
|
void |
onNext(ReefServiceProtos.JobStatusProto value)
Handles an event.
|
void |
send(byte[] message)
Send a message to the Driver.
|
String |
toString() |
public void close()
RunningJob
close
in interface AutoCloseable
close
in interface RunningJob
public void close(byte[] message)
RunningJob
close
in interface RunningJob
message
- delivered along with cancel request.public String getId()
Identifiable
getId
in interface RunningJob
getId
in interface Identifiable
public void send(byte[] message)
RunningJob
send
in interface RunningJob
message
- to send to the running driverpublic void onNext(ReefServiceProtos.JobStatusProto value)
EventHandler
onNext
in interface EventHandler<ReefServiceProtos.JobStatusProto>
value
- an eventCopyright © 2017 The Apache Software Foundation. All rights reserved.