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. |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
static HardwareDescription |
HardwareDescription.extractFromSystem(long managedMemory) |
HardwareDescription |
Instance.getResources() |
Modifier and Type | Method and Description |
---|---|
InstanceID |
InstanceManager.registerTaskManager(akka.actor.ActorRef taskManager,
InstanceConnectionInfo connectionInfo,
HardwareDescription resources,
int numberOfSlots,
UUID leaderSessionID)
Registers a task manager.
|
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 |
---|---|
HardwareDescription |
RegistrationMessages.RegisterTaskManager.resources() |
Constructor and Description |
---|
RegisterTaskManager(InstanceConnectionInfo connectionInfo,
HardwareDescription resources,
int numberOfSlots) |
Modifier and Type | Method and Description |
---|---|
protected HardwareDescription |
TaskManager.resources()
The TaskManager's physical execution resources
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.