Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.jobmanager.slots | |
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. |
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 |
---|---|
InstanceID |
StackTrace.getInstanceId() |
InstanceID |
Messages.Disconnect.instanceId() |
InstanceID |
TaskManagerMessages.Heartbeat.instanceID() |
InstanceID |
TaskManagerMessages.StackTrace.instanceID() |
InstanceID |
JobManagerMessages.RequestTaskManagerInstance.instanceID() |
InstanceID |
JobManagerMessages.RequestStackTrace.instanceID() |
InstanceID |
RegistrationMessages.AcknowledgeRegistration.instanceID() |
InstanceID |
RegistrationMessages.AlreadyRegistered.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) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.