Constructor and Description |
---|
PartialInputChannelDeploymentDescriptor(IntermediateDataSetID resultId,
ResultPartitionID partitionID,
TaskManagerLocation partitionTaskManagerLocation,
int partitionConnectionIndex) |
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
ArchivedExecution.getAssignedResourceLocation() |
TaskManagerLocation |
Execution.getAssignedResourceLocation() |
TaskManagerLocation |
AccessExecution.getAssignedResourceLocation()
Returns the
TaskManagerLocation for this execution. |
TaskManagerLocation |
AccessExecutionVertex.getCurrentAssignedResourceLocation()
Returns the
TaskManagerLocation for this execution vertex. |
TaskManagerLocation |
ExecutionVertex.getCurrentAssignedResourceLocation() |
TaskManagerLocation |
ArchivedExecutionVertex.getCurrentAssignedResourceLocation() |
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 |
---|---|
CompletableFuture<Collection<TaskManagerLocation>> |
Execution.calculatePreferredLocations(LocationPreferenceConstraint locationPreferenceConstraint)
Calculates the preferred locations based on the location preference constraint.
|
CompletableFuture<TaskManagerLocation> |
ExecutionVertex.getCurrentTaskManagerLocationFuture() |
Collection<CompletableFuture<TaskManagerLocation>> |
ExecutionVertex.getPreferredLocations()
Gets the overall preferred execution location for this vertex's current execution.
|
Collection<CompletableFuture<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.
|
Collection<CompletableFuture<TaskManagerLocation>> |
ExecutionVertex.getPreferredLocationsBasedOnState()
Gets the preferred location to execute the current task execution attempt, based on the state
that the execution attempt will resume.
|
CompletableFuture<TaskManagerLocation> |
Execution.getTaskManagerLocationFuture() |
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 |
---|---|
CompletableFuture<SimpleSlot> |
SlotProvider.allocateSlot(ScheduledUnit task,
boolean allowQueued,
Collection<TaskManagerLocation> preferredLocations)
Allocating slot with specific requirement.
|
CompletableFuture<SimpleSlot> |
SlotPoolGateway.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
CompletableFuture<SimpleSlot> |
SlotPool.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
SimpleSlot |
SlotSharingGroupAssignment.getSlotForTask(CoLocationConstraint constraint,
Iterable<TaskManagerLocation> locationPreferences)
Gets a slot for a task that has a co-location constraint.
|
SimpleSlot |
SlotSharingGroupAssignment.getSlotForTask(JobVertexID vertexID,
Iterable<TaskManagerLocation> locationPreferences)
Gets a slot suitable for the given task vertex.
|
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 |
---|---|
CompletableFuture<SimpleSlot> |
Scheduler.allocateSlot(ScheduledUnit task,
boolean allowQueued,
Collection<TaskManagerLocation> preferredLocations) |
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 |
---|---|
CompletableFuture<RegistrationResponse> |
JobMaster.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
Time timeout) |
CompletableFuture<RegistrationResponse> |
JobMasterGateway.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
Time timeout)
Registers the task manager at the job manager.
|
Modifier and Type | Method and Description |
---|---|
static TaskManagerMetricGroup |
MetricUtils.instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry,
TaskManagerLocation taskManagerLocation,
NetworkEnvironment network) |
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,
TaskManagerMetricGroup taskManagerMetricGroup,
BroadcastVariableManager broadcastVariableManager,
FileCache fileCache,
TaskSlotTable taskSlotTable,
JobManagerTable jobManagerTable,
JobLeaderService jobLeaderService,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
int |
TaskManagerLocation.compareTo(TaskManagerLocation o) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.