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.| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ENDPOINT_ID |
| Constructor and Description |
|---|
YarnContainerRegisterEndpoint()
Instantiates a new yarn container register endpoint.
|
| 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.
|
public static final java.lang.String ENDPOINT_ID
public YarnContainerRegisterEndpoint()
public java.util.Map<java.lang.String,java.lang.Object> invoke()
public void register(java.lang.String containerId,
java.lang.String trackUrl)
ContainerRegisterEvent via
YarnEventPublisher if enabled.containerId - the container idtrackUrl - the track url@Autowired(required=false) public void setYarnEventPublisher(YarnEventPublisher yarnEventPublisher)
yarnEventPublisher - the new yarn event publisher