Package | Description |
---|---|
org.apache.flink.runtime.instance | |
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(akka.actor.ActorRef taskManager,
InstanceConnectionInfo connectionInfo,
HardwareDescription resources,
int numberOfSlots,
UUID leaderSessionID)
Registers a task manager.
|
Modifier and Type | Method and Description |
---|---|
Instance |
InstanceManager.getRegisteredInstanceById(InstanceID instanceID) |
boolean |
InstanceManager.reportHeartBeat(InstanceID instanceId,
byte[] lastMetricsReport) |
Constructor and Description |
---|
Instance(ActorGateway actorGateway,
InstanceConnectionInfo connectionInfo,
InstanceID id,
HardwareDescription resources,
int numberOfSlots)
Constructs an instance reflecting a registered TaskManager.
|
Modifier and Type | Method and Description |
---|---|
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) |
Heartbeat(InstanceID instanceID,
byte[] metricsReport,
scala.collection.Seq<AccumulatorSnapshot> accumulators) |
RequestStackTrace(InstanceID instanceID) |
RequestTaskManagerInstance(InstanceID instanceID) |
StackTrace(InstanceID instanceID,
String stackTrace) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.