org.springframework.yarn.boot.actuate.endpoint

Class YarnContainerClusterEndpoint

java.lang.Object

org.springframework.boot.actuate.endpoint.AbstractEndpoint<java.util.Map<java.lang.String,ContainerCluster>>

org.springframework.yarn.boot.actuate.endpoint.YarnContainerClusterEndpoint

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.boot.actuate.endpoint.Endpoint<java.util.Map<java.lang.String,ContainerCluster>>, org.springframework.context.EnvironmentAware

public class YarnContainerClusterEndpoint
extends org.springframework.boot.actuate.endpoint.AbstractEndpoint<java.util.Map<java.lang.String,ContainerCluster>>
implements org.springframework.beans.factory.InitializingBean

Endpoint handling operations against ContainerClusterAppmaster.

Author:

Janne Valkealahti

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ENDPOINT_ID

Constructor Summary

Constructors

Constructor and Description
YarnContainerClusterEndpoint() Instantiates a new yarn container cluster endpoint.

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
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	setYarnAppmaster(YarnAppmaster yarnAppmaster) Sets ContainerClusterAppmaster if passed YarnAppmaster is instance of it.
void	startCluster(java.lang.String clusterId)
void	stopCluster(java.lang.String clusterId)

Methods inherited from class org.springframework.boot.actuate.endpoint.AbstractEndpoint

getEnvironment, getId, isEnabled, isSensitive, setEnabled, setEnvironment, setId, setSensitive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ENDPOINT_ID

public static final java.lang.String ENDPOINT_ID

See Also:

Constant Field Values

Constructor Detail

YarnContainerClusterEndpoint

public YarnContainerClusterEndpoint()

Instantiates a new yarn container cluster endpoint.

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

invoke

public java.util.Map<java.lang.String,ContainerCluster> invoke()

Specified by:

invoke in interface org.springframework.boot.actuate.endpoint.Endpoint<java.util.Map<java.lang.String,ContainerCluster>>

setYarnAppmaster

@Autowired
public void setYarnAppmaster(YarnAppmaster yarnAppmaster)

Sets ContainerClusterAppmaster if passed YarnAppmaster is instance of it.

Parameters:

yarnAppmaster - the yarn application master

getClusters

public java.util.Map<java.lang.String,ContainerCluster> getClusters()

createCluster

public ContainerCluster createCluster(java.lang.String clusterId,
                             java.lang.String clusterDef,
                             ProjectionData projectionData,
                             java.util.Map<java.lang.String,java.lang.Object> extraProperties)

startCluster

public void startCluster(java.lang.String clusterId)

stopCluster

public void stopCluster(java.lang.String clusterId)

destroyCluster

public void destroyCluster(java.lang.String clusterId)

modifyCluster

public void modifyCluster(java.lang.String id,
                 ProjectionData projectionData)