org.springframework.yarn.integration.container

Class AbstractIntegrationYarnContainer

java.lang.Object

org.springframework.yarn.support.LifecycleObjectSupport

org.springframework.yarn.container.AbstractYarnContainer

org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, LongRunningYarnContainer, YarnContainer, YarnContainerRuntime

Direct Known Subclasses:

AbstractBatchYarnContainer

public abstract class AbstractIntegrationYarnContainer
extends AbstractYarnContainer

Base implementation of YarnContainer extending AbstractYarnContainer to handle IntegrationAppmasterServiceClient.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
AbstractIntegrationYarnContainer()

Method Summary

Methods

Modifier and Type	Method and Description
IntegrationAppmasterServiceClient<?>	getIntegrationServiceClient() Gets the integration service client.
void	setIntegrationServiceClient(IntegrationAppmasterServiceClient<?> integrationServiceClient) Sets the integration service client.

Methods inherited from class org.springframework.yarn.container.AbstractYarnContainer

addContainerStateListener, getConfiguration, getEnvironment, getEnvironment, getParameters, isWaitCompleteState, notifyCompleted, notifyCompleted, notifyContainerState, run, runInternal, setConfiguration, setEnvironment, setParameters

Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport

afterPropertiesSet, doStart, doStop, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractIntegrationYarnContainer

public AbstractIntegrationYarnContainer()

Method Detail

setIntegrationServiceClient

public void setIntegrationServiceClient(IntegrationAppmasterServiceClient<?> integrationServiceClient)

Sets the integration service client.

Parameters:

integrationServiceClient - the new integration service client

getIntegrationServiceClient

public IntegrationAppmasterServiceClient<?> getIntegrationServiceClient()

Gets the integration service client.

Returns:

the integration service client