Package | Description |
---|---|
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager | |
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 | |
org.apache.flink.yarn |
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 |
---|---|
scala.collection.mutable.Map<akka.actor.ActorRef,InstanceID> |
JobManager.taskManagerMap() |
Modifier and Type | Method and Description |
---|---|
void |
TaskManagerGateway.disconnectFromJobManager(InstanceID instanceId,
Exception cause)
Disconnect the task manager from the job manager.
|
void |
ActorTaskManagerGateway.disconnectFromJobManager(InstanceID instanceId,
Exception cause) |
Modifier and Type | Method and Description |
---|---|
void |
RpcTaskManagerGateway.disconnectFromJobManager(InstanceID instanceId,
Exception cause) |
Modifier and Type | Method and Description |
---|---|
InstanceID |
StackTrace.getInstanceId() |
InstanceID |
Messages.Disconnect.instanceId() |
InstanceID |
RegistrationMessages.AcknowledgeRegistration.instanceID() |
InstanceID |
RegistrationMessages.AlreadyRegistered.instanceID() |
InstanceID |
TaskManagerMessages.Heartbeat.instanceID() |
InstanceID |
TaskManagerMessages.StackTrace.instanceID() |
InstanceID |
JobManagerMessages.RequestTaskManagerInstance.instanceID() |
InstanceID |
JobManagerMessages.RequestStackTrace.instanceID() |
Constructor and Description |
---|
AcknowledgeRegistration(InstanceID instanceID,
int blobPort) |
AlreadyRegistered(InstanceID instanceID,
int blobPort) |
Disconnect(InstanceID instanceId,
Exception cause) |
Heartbeat(InstanceID instanceID,
scala.collection.Seq<AccumulatorSnapshot> accumulators) |
RequestStackTrace(InstanceID instanceID) |
RequestTaskManagerInstance(InstanceID instanceID) |
StackTrace(InstanceID instanceId,
String stackTrace) |
StackTrace(InstanceID instanceID,
String stackTrace) |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerGateway.notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceId,
SlotID slotID,
AllocationID oldAllocationId)
Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
|
void |
ResourceManager.notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceID,
SlotID slotId,
AllocationID allocationId)
Notification from a TaskExecutor that a slot has become available
|
void |
StandaloneResourceManager.stopWorker(InstanceID instanceId) |
abstract void |
ResourceManager.stopWorker(InstanceID instanceId) |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskExecutorConnection.getInstanceID() |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskManagerRegistration.getInstanceId() |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerActions.releaseResource(InstanceID instanceId) |
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 |
TaskExecutorToResourceManagerConnection.getRegistrationId()
Gets the ID under which the TaskExecutor is registered at the ResourceManager.
|
InstanceID |
TaskExecutorRegistrationSuccess.getRegistrationId()
Gets the ID that the ResourceManager assigned the registration.
|
Constructor and Description |
---|
TaskExecutorRegistrationSuccess(InstanceID registrationId,
ResourceID resourceManagerResourceId,
long heartbeatInterval)
Create a new
TaskExecutorRegistrationSuccess message. |
Modifier and Type | Method and Description |
---|---|
void |
YarnResourceManager.stopWorker(InstanceID instanceId) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.