public class DefaultAllocateCountTracker extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
DefaultAllocateCountTracker.AllocateCountInfo |
| Constructor and Description |
|---|
DefaultAllocateCountTracker(Configuration configuration)
Instantiates a new default allocate count tracker.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addContainers(ContainerAllocateData containerAllocateData)
Adds new count of containers into 'host', 'rack'
and 'any' pending requests.
|
void |
addContainers(int count)
Adds new count of containers into 'any'
pending requests.
|
DefaultAllocateCountTracker.AllocateCountInfo |
getAllocateCounts()
Gets the allocate counts which should be used
to create allocate requests.
|
Container |
processAllocatedContainer(Container container) |
String |
toString() |
public DefaultAllocateCountTracker(Configuration configuration)
configuration - the hadoop configurationpublic void addContainers(int count)
count - the count to addpublic void addContainers(ContainerAllocateData containerAllocateData)
containerAllocateData - the container allocate datapublic DefaultAllocateCountTracker.AllocateCountInfo getAllocateCounts()