public abstract class BaseProtocol extends RpcDispatcher
Modifier and Type | Class and Description |
---|---|
protected static class |
BaseProtocol.CancelJob |
protected static class |
BaseProtocol.EndSession |
protected static class |
BaseProtocol.Error |
protected static class |
BaseProtocol.JobMetrics |
protected static class |
BaseProtocol.JobRequest<T extends Serializable> |
static class |
BaseProtocol.JobResult<T extends Serializable> |
protected static class |
BaseProtocol.JobStarted |
protected static class |
BaseProtocol.JobSubmitted
Inform the client that a new spark job has been submitted for the client job.
|
protected static class |
BaseProtocol.SyncJobRequest<T extends Serializable> |
Constructor and Description |
---|
BaseProtocol() |
channelInactive, channelRead0, exceptionCaught, name
acceptInboundMessage, channelRead
channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
Copyright © 2022 The Apache Software Foundation. All rights reserved.