public class YarnContainerRegisterEndpoint extends org.springframework.boot.actuate.endpoint.AbstractEndpoint<Map<String,Object>>
Endpoint handling graceful shutdown of YARN application.| Modifier and Type | Field and Description |
|---|---|
static String |
ENDPOINT_ID |
| Constructor and Description |
|---|
YarnContainerRegisterEndpoint()
Instantiates a new yarn container register endpoint.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
invoke() |
void |
register(String containerId,
String trackUrl)
Do a registration of a container id and its tracking url.
|
void |
setYarnEventPublisher(org.springframework.yarn.event.YarnEventPublisher yarnEventPublisher)
Sets the yarn event publisher.
|
public static final String ENDPOINT_ID
public YarnContainerRegisterEndpoint()
public void register(String containerId, String trackUrl)
ContainerRegisterEvent via
YarnEventPublisher if enabled.containerId - the container idtrackUrl - the track url@Autowired(required=false) public void setYarnEventPublisher(org.springframework.yarn.event.YarnEventPublisher yarnEventPublisher)
yarnEventPublisher - the new yarn event publisher