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