Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
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.jobmanager.scheduler | |
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. |
org.apache.flink.runtime.minicluster | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.yarn |
Constructor and Description |
---|
MesosTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService,
MetricRegistry metricRegistry) |
Constructor and Description |
---|
PartialInputChannelDeploymentDescriptor(IntermediateDataSetID resultId,
ResultPartitionID partitionID,
TaskManagerLocation partitionTaskManagerLocation,
int partitionConnectionIndex) |
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
Execution.getAssignedResourceLocation() |
TaskManagerLocation |
ArchivedExecution.getAssignedResourceLocation() |
TaskManagerLocation |
AccessExecution.getAssignedResourceLocation()
Returns the
TaskManagerLocation for this execution. |
TaskManagerLocation |
ExecutionVertex.getCurrentAssignedResourceLocation() |
TaskManagerLocation |
ArchivedExecutionVertex.getCurrentAssignedResourceLocation() |
TaskManagerLocation |
AccessExecutionVertex.getCurrentAssignedResourceLocation()
Returns the
TaskManagerLocation for this execution vertex. |
Modifier and Type | Method and Description |
---|---|
Iterable<TaskManagerLocation> |
ExecutionVertex.getPreferredLocations()
Gets the location preferences of this task, determined by the locations of the predecessors from which
it receives input data.
|
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
Slot.getTaskManagerLocation()
Gets the location info of the TaskManager that offers this slot.
|
TaskManagerLocation |
Instance.getTaskManagerLocation() |
Modifier and Type | Method and Description |
---|---|
InstanceID |
InstanceManager.registerTaskManager(TaskManagerGateway taskManagerGateway,
TaskManagerLocation taskManagerLocation,
HardwareDescription resources,
int numberOfSlots)
Registers a task manager.
|
Constructor and Description |
---|
Instance(TaskManagerGateway taskManagerGateway,
TaskManagerLocation location,
InstanceID id,
HardwareDescription resources,
int numberOfSlots)
Constructs an instance reflecting a registered TaskManager.
|
SharedSlot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SlotSharingGroupAssignment assignmentGroup)
Creates a new shared slot that has no parent (is a root slot) and does not belong to any task group.
|
SharedSlot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SlotSharingGroupAssignment assignmentGroup,
SharedSlot parent,
AbstractID groupId)
Creates a new shared slot that has is a sub-slot of the given parent shared slot, and that belongs
to the given task group.
|
SimpleSlot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway)
Creates a new simple slot that stands alone and does not belong to shared slot.
|
SimpleSlot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SharedSlot parent,
AbstractID groupID)
Creates a new simple slot that belongs to the given shared slot and
is identified by the given ID.
|
Slot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SharedSlot parent,
AbstractID groupID)
Base constructor for slots.
|
Constructor and Description |
---|
ConnectionID(TaskManagerLocation connectionInfo,
int connectionIndex) |
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
CoLocationConstraint.getLocation()
Gets the location assigned to this slot.
|
Modifier and Type | Method and Description |
---|---|
protected SimpleSlot |
Scheduler.getFreeSlotForTask(ExecutionVertex vertex,
Iterable<TaskManagerLocation> requestedLocations,
boolean localOnly)
Gets a suitable instance to schedule the vertex execution to.
|
protected SimpleSlot |
Scheduler.getNewSlotForSharingGroup(ExecutionVertex vertex,
Iterable<TaskManagerLocation> requestedLocations,
SlotSharingGroupAssignment groupAssignment,
CoLocationConstraint constraint,
boolean localOnly)
Tries to allocate a new slot for a vertex that is part of a slot sharing group.
|
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
AllocatedSlot.getTaskManagerLocation()
Gets the location info of the TaskManager that offers this slot.
|
Constructor and Description |
---|
AllocatedSlot(AllocationID slotAllocationId,
JobID jobID,
TaskManagerLocation location,
int slotNumber,
ResourceProfile resourceProfile,
TaskManagerGateway taskManagerGateway) |
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
RegistrationMessages.RegisterTaskManager.connectionInfo() |
Constructor and Description |
---|
RegisterTaskManager(ResourceID resourceId,
TaskManagerLocation connectionInfo,
HardwareDescription resources,
int numberOfSlots) |
Modifier and Type | Method and Description |
---|---|
akka.actor.Props |
LocalFlinkMiniCluster.getTaskManagerProps(Class<? extends TaskManager> taskManagerClass,
TaskManagerConfiguration taskManagerConfig,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
LeaderRetrievalService leaderRetrievalService,
MetricRegistry metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
protected TaskManagerLocation |
TaskManager.location() |
Modifier and Type | Method and Description |
---|---|
scala.Tuple7<TaskManagerConfiguration,TaskManagerLocation,MemoryManager,IOManager,NetworkEnvironment,LeaderRetrievalService,MetricRegistry> |
TaskManager$.createTaskManagerComponents(Configuration configuration,
ResourceID resourceID,
String taskManagerHostname,
boolean localTaskManagerCommunication,
scala.Option<LeaderRetrievalService> leaderRetrievalServiceOption) |
static scala.Tuple7<TaskManagerConfiguration,TaskManagerLocation,MemoryManager,IOManager,NetworkEnvironment,LeaderRetrievalService,MetricRegistry> |
TaskManager.createTaskManagerComponents(Configuration configuration,
ResourceID resourceID,
String taskManagerHostname,
boolean localTaskManagerCommunication,
scala.Option<LeaderRetrievalService> leaderRetrievalServiceOption) |
Modifier and Type | Method and Description |
---|---|
int |
TaskManagerLocation.compareTo(TaskManagerLocation o) |
akka.actor.Props |
TaskManager$.getTaskManagerProps(Class<? extends TaskManager> taskManagerClass,
TaskManagerConfiguration taskManagerConfig,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
LeaderRetrievalService leaderRetrievalService,
MetricRegistry metricsRegistry) |
static akka.actor.Props |
TaskManager.getTaskManagerProps(Class<? extends TaskManager> taskManagerClass,
TaskManagerConfiguration taskManagerConfig,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
LeaderRetrievalService leaderRetrievalService,
MetricRegistry metricsRegistry) |
Constructor and Description |
---|
TaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation location,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService,
MetricRegistry metricsRegistry) |
Constructor and Description |
---|
YarnTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService,
MetricRegistry metricRegistry) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.