public interface MasterContainerAllocatorConfigurer extends org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerBuilder<YarnAppmasterConfigurer>
AnnotationConfigurerBuilder for configuring ContainerAllocator.
@Configuration
@EnableYarn(enable=Enable.APPMASTER)
static class Config extends SpringYarnConfigurerAdapter {
@Override
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.withContainerAllocator();
}
}
| Modifier and Type | Method and Description |
|---|---|
MasterContainerAllocatorConfigurer |
locality(boolean locality)
Specify a locality relaxing for
ContainerAllocator. |
MasterContainerAllocatorConfigurer |
memory(int memory)
Specify a container memory for
ContainerAllocator. |
MasterContainerAllocatorConfigurer |
memory(String memory)
Specify a container memory for
ContainerAllocator. |
MasterContainerAllocatorConfigurer |
priority(Integer priority)
Specify a container priority for
ContainerAllocator. |
MasterContainerAllocatorConfigurer |
virtualCores(Integer virtualCores)
Specify a container virtual cores for
ContainerAllocator. |
MasterContainerAllocatorConfigurer priority(Integer priority)
ContainerAllocator.
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.withContainerAllocator()
.priority(0);
}
<yarn:master> <yarn:container-allocator priority="0"/> </yarn:master>
priority - the priorityMasterContainerAllocatorConfigurer for chainingMasterContainerAllocatorConfigurer virtualCores(Integer virtualCores)
ContainerAllocator.
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.withContainerAllocator()
.virtualCores(1);
}
<yarn:master> <yarn:container-allocator virtualcores="1"/> </yarn:master>
virtualCores - the virtual coresMasterContainerAllocatorConfigurer for chainingMasterContainerAllocatorConfigurer memory(String memory)
ContainerAllocator.
The memory argument is given as MegaBytes if
value is a plain number. Shortcuts like 1G and
500M can be used which translates to 1024
and 500 respectively.
This method is equivalent to #memory(int) so that
argument can be given as a String.
NOTE: be careful not to use a too low settings like
1000K or 1000B because those are rounded
down to full MBs and thus becomes a zero. Also too
high values may make resource allocation to behave badly.
JavaConfig:
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.withContainerAllocator()
.memory("1G");
}
<yarn:master> <yarn:container-allocator memory="1024"/> </yarn:master>
memory - the memoryMasterContainerAllocatorConfigurer for chainingMasterContainerAllocatorConfigurer memory(int memory)
ContainerAllocator.
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.withContainerAllocator()
.memory(1024);
}
<yarn:master> <yarn:container-allocator memory="1024"/> </yarn:master>
memory - the memoryMasterContainerAllocatorConfigurer for chainingmemory(String)MasterContainerAllocatorConfigurer locality(boolean locality)
ContainerAllocator. Setting
this flag true means that resource requests will
not use locality relaxing. Default for this flag is false.
public void configure(YarnAppmasterConfigure master) throws Exception {
master
.withContainerAllocator()
.locality(false);
}
<yarn:master> <yarn:container-allocator locality="false"/> </yarn:master>
locality - the locality flag for resource relaxingMasterContainerAllocatorConfigurer for chaining