public class YarnContainerClusterEndpoint extends org.springframework.boot.actuate.endpoint.AbstractEndpoint<Map<String,org.springframework.yarn.am.cluster.ContainerCluster>> implements ApplicationContextAware
Endpoint handling operations against ContainerClusterAppmaster.| Modifier and Type | Field and Description |
|---|---|
static String |
ENDPOINT_ID |
| Constructor and Description |
|---|
YarnContainerClusterEndpoint()
Instantiates a new yarn container cluster endpoint.
|
| Modifier and Type | Method and Description |
|---|---|
org.springframework.yarn.am.cluster.ContainerCluster |
createCluster(String clusterId,
String clusterDef,
org.springframework.yarn.am.grid.support.ProjectionData projectionData,
Map<String,Object> extraProperties) |
void |
destroyCluster(String clusterId) |
Map<String,org.springframework.yarn.am.cluster.ContainerCluster> |
getClusters() |
Map<String,org.springframework.yarn.am.cluster.ContainerCluster> |
invoke() |
void |
modifyCluster(String id,
org.springframework.yarn.am.grid.support.ProjectionData projectionData) |
void |
setApplicationContext(ApplicationContext applicationContext) |
void |
startCluster(String clusterId) |
void |
stopCluster(String clusterId) |
public static final String ENDPOINT_ID
public YarnContainerClusterEndpoint()
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext in interface ApplicationContextAwareBeansExceptionpublic org.springframework.yarn.am.cluster.ContainerCluster createCluster(String clusterId, String clusterDef, org.springframework.yarn.am.grid.support.ProjectionData projectionData, Map<String,Object> extraProperties)
public void startCluster(String clusterId)
public void stopCluster(String clusterId)
public void destroyCluster(String clusterId)
public void modifyCluster(String id, org.springframework.yarn.am.grid.support.ProjectionData projectionData)