Package | Description |
---|---|
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.slots | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.resourcemanager.registration | |
org.apache.flink.runtime.resourcemanager.slotmanager | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskManagerSlot.getInstanceId() |
Modifier and Type | Method and Description |
---|---|
InstanceID |
Instance.getId() |
InstanceID |
InstanceManager.registerTaskManager(TaskManagerGateway taskManagerGateway,
TaskManagerLocation taskManagerLocation,
HardwareDescription resources,
int numberOfSlots)
Registers a task manager.
|
Modifier and Type | Method and Description |
---|---|
Instance |
InstanceManager.getRegisteredInstanceById(InstanceID instanceID) |
boolean |
InstanceManager.isRegistered(InstanceID instanceId) |
boolean |
InstanceManager.reportHeartBeat(InstanceID instanceId) |
void |
InstanceManager.unregisterTaskManager(InstanceID instanceId,
boolean terminated)
Unregisters the TaskManager with the given instance id.
|
Constructor and Description |
---|
Instance(TaskManagerGateway taskManagerGateway,
TaskManagerLocation location,
InstanceID id,
HardwareDescription resources,
int numberOfSlots)
Constructs an instance reflecting a registered TaskManager.
|
Modifier and Type | Method and Description |
---|---|
void |
ActorTaskManagerGateway.disconnectFromJobManager(InstanceID instanceId,
Exception cause) |
void |
TaskManagerGateway.disconnectFromJobManager(InstanceID instanceId,
Exception cause)
Disconnect the task manager from the job manager.
|
Modifier and Type | Method and Description |
---|---|
void |
RpcTaskManagerGateway.disconnectFromJobManager(InstanceID instanceId,
Exception cause) |
Modifier and Type | Method and Description |
---|---|
InstanceID |
StackTrace.getInstanceId() |
Constructor and Description |
---|
StackTrace(InstanceID instanceId,
String stackTrace) |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerGateway.notifySlotAvailable(InstanceID instanceId,
SlotID slotID,
AllocationID oldAllocationId)
Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
|
void |
ResourceManager.notifySlotAvailable(InstanceID instanceID,
SlotID slotId,
AllocationID allocationId) |
protected void |
ResourceManager.releaseResource(InstanceID instanceId,
Exception cause) |
CompletableFuture<Acknowledge> |
ResourceManagerGateway.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout)
Sends the given
SlotReport to the ResourceManager. |
CompletableFuture<Acknowledge> |
ResourceManager.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskExecutorConnection.getInstanceID() |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskManagerRegistration.getInstanceId() |
Modifier and Type | Method and Description |
---|---|
int |
SlotManager.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
SlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId) |
void |
ResourceActions.releaseResource(InstanceID instanceId,
Exception cause)
Releases the resource with the given instance id.
|
boolean |
SlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
SlotManager.unregisterTaskManager(InstanceID instanceId)
Unregisters the task manager identified by the given instance id and its associated slots
from the slot manager.
|
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskExecutorRegistrationSuccess.getRegistrationId()
Gets the ID that the ResourceManager assigned the registration.
|
Constructor and Description |
---|
TaskExecutorRegistrationSuccess(InstanceID registrationId,
ResourceID resourceManagerResourceId,
ClusterInformation clusterInformation)
Create a new
TaskExecutorRegistrationSuccess message. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.