public class StatsPerDag extends Object
Constructor and Description |
---|
StatsPerDag() |
Modifier and Type | Method and Description |
---|---|
int |
getNumAllocationsNoLocalityRequest() |
Map<String,AtomicInteger> |
getNumAllocationsPerHost() |
int |
getNumDelayedAllocations() |
int |
getNumLocalAllocations() |
int |
getNumNonLocalAllocations() |
int |
getNumPreemptedTasks() |
int |
getNumRejectedTasks() |
int |
getNumTotalAllocations() |
void |
registerCommFailure(String host) |
void |
registerDelayedAllocation() |
void |
registerTaskAllocated(String[] requestedHosts,
String[] requestedRacks,
String allocatedHost) |
void |
registerTaskPreempted(String host) |
void |
registerTaskRejected(String host) |
void |
registerTaskRequest(String[] requestedHosts,
String[] requestedRacks)
Update DAG metrics caused by an incoming allocate Task call.
|
String |
toString() |
public int getNumTotalAllocations()
public int getNumLocalAllocations()
public int getNumNonLocalAllocations()
public int getNumAllocationsNoLocalityRequest()
public int getNumPreemptedTasks()
public int getNumRejectedTasks()
public int getNumDelayedAllocations()
public Map<String,AtomicInteger> getNumAllocationsPerHost()
public void registerTaskRequest(String[] requestedHosts, String[] requestedRacks)
requestedHosts
- requestedRacks
- public void registerTaskAllocated(String[] requestedHosts, String[] requestedRacks, String allocatedHost)
public void registerTaskPreempted(String host)
public void registerCommFailure(String host)
public void registerTaskRejected(String host)
public void registerDelayedAllocation()
Copyright © 2022 The Apache Software Foundation. All rights reserved.