Interface | Description |
---|---|
JobManagerGateway |
Public JobManager gateway.
|
JobMasterGateway |
JobMaster rpc gateway interface |
Class | Description |
---|---|
JMTMRegistrationSuccess | |
JobManagerRunner |
The runner for the job manager.
|
JobManagerServices |
Utility class to hold all auxiliary services used by the
JobMaster . |
JobMaster |
JobMaster implementation.
|
JobMasterId |
The
JobMaster fencing token. |
JobMasterRegistrationSuccess |
Base class for responses from the ResourceManager to a registration attempt by a JobMaster.
|
RpcTaskManagerGateway |
Implementation of the
TaskManagerGateway for Flink's RPC system |
SerializedInputSplit |
Exception | Description |
---|---|
ExecutionGraphException |
Exceptions thrown by operations on the
ExecutionGraph by the JobMaster . |
JobManagerException |
Base exception thrown by the
JobMaster . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.