| Package | Description |
|---|---|
| org.apache.flink.runtime.jobmaster | |
| org.apache.flink.runtime.registration | |
| org.apache.flink.runtime.taskexecutor |
| Modifier and Type | Class and Description |
|---|---|
class |
JMTMRegistrationSuccess
Message indicating a successful
JobMaster and TaskExecutor registration. |
class |
JobMasterRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a JobMaster.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RegisteredRpcConnection<F extends Serializable,G extends RpcGateway,S extends RegistrationResponse.Success>
This utility class implements the basis of RPC connecting from one component to another component,
for example the RPC connection from TaskExecutor to ResourceManager.
|
interface |
RegistrationConnectionListener<T extends RegisteredRpcConnection<?,?,S>,S extends RegistrationResponse.Success>
Classes which want to be notified about the registration result by the
RegisteredRpcConnection
have to implement this interface. |
class |
RetryingRegistration<F extends Serializable,G extends RpcGateway,S extends RegistrationResponse.Success>
This utility class implements the basis of registering one component at another component,
for example registering the TaskExecutor at the ResourceManager.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TaskExecutorRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a
TaskExecutor.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.