Uses of Class
org.apache.flink.runtime.resourcemanager.TaskExecutorRegistration
-
Packages that use TaskExecutorRegistration Package Description org.apache.flink.runtime.resourcemanager org.apache.flink.runtime.taskexecutor -
-
Uses of TaskExecutorRegistration in org.apache.flink.runtime.resourcemanager
Methods in org.apache.flink.runtime.resourcemanager with parameters of type TaskExecutorRegistration Modifier and Type Method Description CompletableFuture<RegistrationResponse>
ResourceManager. registerTaskExecutor(TaskExecutorRegistration taskExecutorRegistration, Duration timeout)
CompletableFuture<RegistrationResponse>
ResourceManagerGateway. registerTaskExecutor(TaskExecutorRegistration taskExecutorRegistration, Duration timeout)
Register aTaskExecutor
at the resource manager. -
Uses of TaskExecutorRegistration in org.apache.flink.runtime.taskexecutor
Constructors in org.apache.flink.runtime.taskexecutor with parameters of type TaskExecutorRegistration Constructor Description TaskExecutorToResourceManagerConnection(org.slf4j.Logger log, RpcService rpcService, RetryingRegistrationConfiguration retryingRegistrationConfiguration, String resourceManagerAddress, ResourceManagerId resourceManagerId, Executor executor, RegistrationConnectionListener<TaskExecutorToResourceManagerConnection,TaskExecutorRegistrationSuccess,TaskExecutorRegistrationRejection> registrationListener, TaskExecutorRegistration taskExecutorRegistration)
-