org.springframework.yarn.boot.actuate.endpoint

Class YarnContainerRegisterEndpoint

java.lang.Object

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

org.springframework.yarn.boot.actuate.endpoint.YarnContainerRegisterEndpoint

All Implemented Interfaces:

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

public class YarnContainerRegisterEndpoint
extends org.springframework.boot.actuate.endpoint.AbstractEndpoint<java.util.Map<java.lang.String,java.lang.Object>>

Endpoint handling graceful shutdown of YARN application.

Author:

Janne Valkealahti

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
YarnContainerRegisterEndpoint() Instantiates a new yarn container register endpoint.

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	invoke()
void	register(java.lang.String containerId, java.lang.String trackUrl) Do a registration of a container id and its tracking url.
void	setYarnEventPublisher(YarnEventPublisher yarnEventPublisher) Sets the yarn event publisher.

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

YarnContainerRegisterEndpoint

public YarnContainerRegisterEndpoint()

Instantiates a new yarn container register endpoint.

Method Detail

invoke

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

register

public void register(java.lang.String containerId,
            java.lang.String trackUrl)

Do a registration of a container id and its tracking url. This will initiate an ContainerRegisterEvent via YarnEventPublisher if enabled.

Parameters:

containerId - the container id

trackUrl - the track url

setYarnEventPublisher

@Autowired(required=false)
public void setYarnEventPublisher(YarnEventPublisher yarnEventPublisher)

Sets the yarn event publisher.

Parameters:

yarnEventPublisher - the new yarn event publisher