Uses of Interface
org.apache.flink.runtime.taskexecutor.TaskExecutorGateway
-
-
Uses of TaskExecutorGateway in org.apache.flink.runtime.io.network.partition
Methods in org.apache.flink.runtime.io.network.partition that return types with arguments of type TaskExecutorGateway Modifier and Type Method Description Optional<TaskExecutorGateway>
PartitionTrackerFactory.TaskExecutorGatewayLookup. lookup(ResourceID taskExecutorId)
Returns aTaskExecutorGateway
corresponding to the given ResourceID. -
Uses of TaskExecutorGateway in org.apache.flink.runtime.jobmaster
Constructors in org.apache.flink.runtime.jobmaster with parameters of type TaskExecutorGateway Constructor Description RpcTaskManagerGateway(TaskExecutorGateway taskExecutorGateway, JobMasterId jobMasterId)
-
Uses of TaskExecutorGateway in org.apache.flink.runtime.resourcemanager.registration
Methods in org.apache.flink.runtime.resourcemanager.registration that return TaskExecutorGateway Modifier and Type Method Description TaskExecutorGateway
TaskExecutorConnection. getTaskExecutorGateway()
Constructors in org.apache.flink.runtime.resourcemanager.registration with parameters of type TaskExecutorGateway Constructor Description TaskExecutorConnection(ResourceID resourceID, TaskExecutorGateway taskExecutorGateway)
WorkerRegistration(TaskExecutorGateway taskExecutorGateway, WorkerType worker, int dataPort, int jmxPort, HardwareDescription hardwareDescription, TaskExecutorMemoryConfiguration memoryConfiguration, ResourceProfile totalResourceProfile, ResourceProfile defaultSlotResourceProfile, String nodeId)
-
Uses of TaskExecutorGateway in org.apache.flink.runtime.taskexecutor
Classes in org.apache.flink.runtime.taskexecutor that implement TaskExecutorGateway Modifier and Type Class Description class
TaskExecutor
TaskExecutor implementation.class
TaskExecutorGatewayDecoratorBase
A class that decorates/forwards calls to aTaskExecutorGateway
.Fields in org.apache.flink.runtime.taskexecutor declared as TaskExecutorGateway Modifier and Type Field Description protected TaskExecutorGateway
TaskExecutorGatewayDecoratorBase. originalGateway
Constructors in org.apache.flink.runtime.taskexecutor with parameters of type TaskExecutorGateway Constructor Description TaskExecutorGatewayDecoratorBase(TaskExecutorGateway originalGateway)
-