Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.io.network | |
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 | |
org.apache.flink.runtime.testingUtils | |
org.apache.flink.yarn |
Constructor and Description |
---|
PartialInputChannelDeploymentDescriptor(IntermediateDataSetID resultId,
ResultPartitionID partitionID,
InstanceConnectionInfo partitionConnectionInfo,
int partitionConnectionIndex) |
Modifier and Type | Method and Description |
---|---|
InstanceConnectionInfo |
Execution.getAssignedResourceLocation() |
InstanceConnectionInfo |
ExecutionVertex.getCurrentAssignedResourceLocation() |
Modifier and Type | Method and Description |
---|---|
InstanceConnectionInfo |
Instance.getInstanceConnectionInfo() |
Modifier and Type | Method and Description |
---|---|
int |
InstanceConnectionInfo.compareTo(InstanceConnectionInfo o) |
InstanceID |
InstanceManager.registerTaskManager(akka.actor.ActorRef taskManager,
ResourceID resourceID,
InstanceConnectionInfo connectionInfo,
HardwareDescription resources,
int numberOfSlots,
UUID leaderSessionID)
Registers a task manager.
|
Constructor and Description |
---|
Instance(ActorGateway actorGateway,
InstanceConnectionInfo connectionInfo,
ResourceID resourceId,
InstanceID id,
HardwareDescription resources,
int numberOfSlots)
Constructs an instance reflecting a registered TaskManager.
|
Constructor and Description |
---|
ConnectionID(InstanceConnectionInfo connectionInfo,
int connectionIndex) |
Modifier and Type | Method and Description |
---|---|
InstanceConnectionInfo |
RegistrationMessages.RegisterTaskManager.connectionInfo() |
Constructor and Description |
---|
RegisterTaskManager(ResourceID resourceId,
InstanceConnectionInfo connectionInfo,
HardwareDescription resources,
int numberOfSlots) |
Modifier and Type | Method and Description |
---|---|
protected InstanceConnectionInfo |
TaskManager.connectionInfo() |
Modifier and Type | Method and Description |
---|---|
scala.Tuple4<TaskManagerConfiguration,NetworkEnvironmentConfiguration,InstanceConnectionInfo,MemoryType> |
TaskManager$.parseTaskManagerConfiguration(Configuration configuration,
String taskManagerHostname,
boolean localTaskManagerCommunication)
Utility method to extract TaskManager config parameters from the configuration and to
sanity check them.
|
static scala.Tuple4<TaskManagerConfiguration,NetworkEnvironmentConfiguration,InstanceConnectionInfo,MemoryType> |
TaskManager.parseTaskManagerConfiguration(Configuration configuration,
String taskManagerHostname,
boolean localTaskManagerCommunication)
Utility method to extract TaskManager config parameters from the configuration and to
sanity check them.
|
Constructor and Description |
---|
TaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
Constructor and Description |
---|
TestingTaskManager(TaskManagerConfiguration config,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
TestingTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
Constructor and Description |
---|
YarnTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.