Modifier and Type | Method and Description |
---|---|
Collection<TaskManagerLocation> |
SlotProfile.getPreferredLocations()
Returns the preferred locations for the slot.
|
Modifier and Type | Method and Description |
---|---|
static SlotProfile |
SlotProfile.priorAllocation(ResourceProfile taskResourceProfile,
ResourceProfile physicalSlotResourceProfile,
Collection<TaskManagerLocation> preferredLocations,
Collection<AllocationID> priorAllocations,
Set<AllocationID> reservedAllocations)
Returns a slot profile for the given resource profile, prior allocations and all prior
allocation ids from the whole execution graph.
|
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
AccessExecution.getAssignedResourceLocation()
Returns the
TaskManagerLocation for this execution. |
TaskManagerLocation |
Execution.getAssignedResourceLocation() |
TaskManagerLocation |
ArchivedExecution.getAssignedResourceLocation() |
TaskManagerLocation |
ExecutionVertex.getCurrentAssignedResourceLocation() |
TaskManagerLocation |
ArchivedExecutionVertex.getCurrentAssignedResourceLocation() |
TaskManagerLocation |
AccessExecutionVertex.getCurrentAssignedResourceLocation()
Returns the
TaskManagerLocation for this execution vertex. |
Modifier and Type | Method and Description |
---|---|
Optional<TaskManagerLocation> |
ExecutionVertex.findLastLocation()
Gets the location that an execution of this vertex was assigned to.
|
CompletableFuture<TaskManagerLocation> |
SpeculativeExecutionVertex.getCurrentTaskManagerLocationFuture() |
CompletableFuture<TaskManagerLocation> |
ExecutionVertex.getCurrentTaskManagerLocationFuture() |
Optional<TaskManagerLocation> |
SpeculativeExecutionVertex.getPreferredLocationBasedOnState() |
Optional<TaskManagerLocation> |
ExecutionVertex.getPreferredLocationBasedOnState()
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() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
Execution.registerProducedPartitions(TaskManagerLocation location) |
Constructor and Description |
---|
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
IOMetrics ioMetrics,
ExecutionAttemptID attemptId,
ExecutionState state,
ErrorInfo failureCause,
TaskManagerLocation assignedResourceLocation,
AllocationID assignedAllocationID,
long[] stateTimestamps,
long[] stateEndTimestamps) |
Constructor and Description |
---|
ConnectionID(TaskManagerLocation connectionInfo,
int connectionIndex) |
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
SlotInfo.getTaskManagerLocation()
Gets the location info of the TaskManager that offers this slot.
|
TaskManagerLocation |
LogicalSlot.getTaskManagerLocation()
Return the TaskManager location of this slot.
|
Modifier and Type | Method and Description |
---|---|
TaskManagerLocation |
SingleLogicalSlot.getTaskManagerLocation() |
TaskManagerLocation |
SlotInfoWithUtilization.getTaskManagerLocation() |
Modifier and Type | Method and Description |
---|---|
Collection<SlotOffer> |
DeclarativeSlotPool.offerSlots(Collection<? extends SlotOffer> offers,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime)
Offers slots to this slot pool.
|
Collection<SlotOffer> |
DefaultDeclarativeSlotPool.offerSlots(Collection<? extends SlotOffer> offers,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Collection<SlotOffer> |
BlocklistDeclarativeSlotPool.offerSlots(Collection<? extends SlotOffer> offers,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Collection<SlotOffer> |
SlotPool.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers)
Offers multiple slots to the
SlotPool . |
Collection<SlotOffer> |
DeclarativeSlotPoolBridge.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers) |
Collection<SlotOffer> |
DeclarativeSlotPoolService.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers) |
Collection<SlotOffer> |
SlotPoolService.offerSlots(TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
Collection<SlotOffer> offers)
Offers multiple slots to the
SlotPoolService . |
Collection<SlotOffer> |
DeclarativeSlotPool.registerSlots(Collection<? extends SlotOffer> slots,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime)
Registers the given set of slots at the slot pool.
|
Collection<SlotOffer> |
DefaultDeclarativeSlotPool.registerSlots(Collection<? extends SlotOffer> slots,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Collection<SlotOffer> |
BlocklistDeclarativeSlotPool.registerSlots(Collection<? extends SlotOffer> slots,
TaskManagerLocation taskManagerLocation,
TaskManagerGateway taskManagerGateway,
long currentTime) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Collection<TaskManagerLocation>> |
PreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
Collection<TaskManagerLocation> |
SyncPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore)
Returns preferred locations of an execution vertex.
|
CompletableFuture<Collection<TaskManagerLocation>> |
DefaultPreferredLocationsRetriever.getPreferredLocations(ExecutionVertexID executionVertexId,
Set<ExecutionVertexID> producersToIgnore) |
Optional<TaskManagerLocation> |
StateLocationRetriever.getStateLocation(ExecutionVertexID executionVertexId)
Returns state location of an execution vertex.
|
Optional<CompletableFuture<TaskManagerLocation>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getTaskManagerLocation(ExecutionVertexID executionVertexId) |
Optional<CompletableFuture<TaskManagerLocation>> |
InputsLocationsRetriever.getTaskManagerLocation(ExecutionVertexID executionVertexId)
Get the task manager location future for an execution.
|
Constructor and Description |
---|
ExceptionHistoryEntry(Throwable cause,
long timestamp,
String failingTaskName,
TaskManagerLocation taskManagerLocation)
Instantiates a
ExceptionHistoryEntry . |
RootExceptionHistoryEntry(Throwable cause,
long timestamp,
String failingTaskName,
TaskManagerLocation taskManagerLocation,
Iterable<ExceptionHistoryEntry> concurrentExceptions)
Instantiates a
RootExceptionHistoryEntry . |
Modifier and Type | Method and Description |
---|---|
static ProducerDescriptor |
ProducerDescriptor.create(TaskManagerLocation producerLocation,
ExecutionAttemptID attemptId) |
Modifier and Type | Method and Description |
---|---|
static TaskManagerLocation |
TaskManagerLocation.fromUnresolvedLocation(UnresolvedTaskManagerLocation unresolvedLocation,
TaskManagerLocation.ResolutionMode resolutionMode) |
Modifier and Type | Method and Description |
---|---|
int |
TaskManagerLocation.compareTo(TaskManagerLocation o) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.