public class DefaultYarnEventPublisher extends Object implements YarnEventPublisher, ApplicationEventPublisherAware
| Constructor and Description |
|---|
DefaultYarnEventPublisher()
Constructs default strategy without an event publisher.
|
DefaultYarnEventPublisher(ApplicationEventPublisher applicationEventPublisher)
Constructs default strategy with an event publisher.
|
| Modifier and Type | Method and Description |
|---|---|
void |
publishContainerAllocated(Object source,
Container container)
Publish an application event containing information
about the allocated
Container. |
void |
publishContainerCompleted(Object source,
ContainerStatus status)
Publish an application event containing information
about the completed
ContainerStatus. |
void |
publishContainerLaunched(Object source,
Container container)
Publish an application event containing information
about the launched
Container. |
void |
publishContainerLaunchRequestFailed(Object source,
Container container)
Publish an application event containing information
about the failed
Container launch request. |
void |
publishEvent(AbstractYarnEvent event)
Publish a general application event of type
AbstractYarnEvent. |
void |
setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
public DefaultYarnEventPublisher()
public DefaultYarnEventPublisher(ApplicationEventPublisher applicationEventPublisher)
applicationEventPublisher - the event publisherpublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface ApplicationEventPublisherAwarepublic void publishContainerAllocated(Object source, Container container)
YarnEventPublisherContainer.publishContainerAllocated in interface YarnEventPublishersource - the component that published the event (never null)container - the Containerpublic void publishContainerLaunched(Object source, Container container)
YarnEventPublisherContainer.publishContainerLaunched in interface YarnEventPublishersource - the component that published the event (never null)container - the Containerpublic void publishContainerLaunchRequestFailed(Object source, Container container)
YarnEventPublisherContainer launch request.publishContainerLaunchRequestFailed in interface YarnEventPublishersource - the component that published the event (never null)container - the Containerpublic void publishContainerCompleted(Object source, ContainerStatus status)
YarnEventPublisherContainerStatus.publishContainerCompleted in interface YarnEventPublishersource - the component that published the event (never null)status - the Container statuspublic void publishEvent(AbstractYarnEvent event)
YarnEventPublisherAbstractYarnEvent.publishEvent in interface YarnEventPublisherevent - the event