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.jobmaster | |
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.taskexecutor | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
protected static TaskManagerLocation |
MesosTaskManager.location() |
Constructor and Description |
---|
MesosTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
HighAvailabilityServices highAvailabilityServices,
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. |
TaskManagerLocation |
ExecutionVertex.getLatestPriorLocation()
Gets the location where the latest completed/canceled/failed execution of the vertex's
task happened.
|
Modifier and Type | Method and Description |
---|---|
Iterable<TaskManagerLocation> |
ExecutionVertex.getPreferredLocations()
Gets the overall preferred execution location for this vertex's current execution.
|
Iterable<TaskManagerLocation> |
ExecutionVertex.getPreferredLocationsBasedOnInputs()
Gets the location preferences of the vertex's current task execution, as determined by the locations
of the predecessors from which it receives input data.
|
Iterable<TaskManagerLocation> |
ExecutionVertex.getPreferredLocationsBasedOnState()
Gets the preferred location to execute the current task execution attempt, based on the state
that the execution attempt will resume.
|
Constructor and Description |
---|
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
IOMetrics ioMetrics,
ExecutionAttemptID attemptId,
int attemptNumber,
ExecutionState state,
String failureCause,
TaskManagerLocation assignedResourceLocation,
int parallelSubtaskIndex,
long[] stateTimestamps) |
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.
|
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
SlotPool.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences) |
Future<SimpleSlot> |
SlotPoolGateway.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
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 |
---|---|
Future<RegistrationResponse> |
JobMaster.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId) |
Future<RegistrationResponse> |
JobMasterGateway.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId,
Time timeout)
Register the task manager at the job manager.
|
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,
MetricRegistry metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
TaskManagerServices.getTaskManagerLocation() |
Constructor and Description |
---|
JobLeaderService(TaskManagerLocation location) |
TaskExecutor(RpcService rpcService,
TaskManagerConfiguration taskManagerConfiguration,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
HighAvailabilityServices haServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
TaskManagerMetricGroup taskManagerMetricGroup,
BroadcastVariableManager broadcastVariableManager,
FileCache fileCache,
TaskSlotTable taskSlotTable,
JobManagerTable jobManagerTable,
JobLeaderService jobLeaderService,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
protected TaskManagerLocation |
TaskManager.location() |
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,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricsRegistry) |
static akka.actor.Props |
TaskManager.getTaskManagerProps(Class<? extends TaskManager> taskManagerClass,
TaskManagerConfiguration taskManagerConfig,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment networkEnvironment,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricsRegistry) |
Constructor and Description |
---|
TaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation location,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
protected static TaskManagerLocation |
YarnTaskManager.location() |
Constructor and Description |
---|
YarnTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricRegistry) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.