org.springframework.yarn.integration.container
Class AbstractIntegrationYarnContainer

java.lang.Object
  org.springframework.yarn.container.AbstractYarnContainer
      org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer

All Implemented Interfaces:

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

AbstractIntegrationYarnContainer()

Method Summary

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 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