A C D E F G H I J K L M N O P Q R S T U V Y

A

AbstractAllocator - Class in org.springframework.yarn.am.allocate
The base class for Container allocator implementations.
AbstractAllocator() - Constructor for class org.springframework.yarn.am.allocate.AbstractAllocator
 
AbstractAppmaster - Class in org.springframework.yarn.am
Base class providing functionality for common application master instances.
AbstractAppmaster() - Constructor for class org.springframework.yarn.am.AbstractAppmaster
 
AbstractCommandLineRunner<T> - Class in org.springframework.yarn.launch
Base implementation used for launching a Spring Application Context and executing a bean using a command line.
AbstractCommandLineRunner() - Constructor for class org.springframework.yarn.launch.AbstractCommandLineRunner
 
AbstractCompositeListener<T> - Class in org.springframework.yarn.listener
Base implementation for all composite listeners.
AbstractCompositeListener() - Constructor for class org.springframework.yarn.listener.AbstractCompositeListener
Constructs instance with an empty listener list.
AbstractEventingAppmaster - Class in org.springframework.yarn.am
Base implementation of application master where life-cycle is based on events rather than a static information existing prior the start of an instance.
AbstractEventingAppmaster() - Constructor for class org.springframework.yarn.am.AbstractEventingAppmaster
 
AbstractLauncher - Class in org.springframework.yarn.am.container
The base class for Container launcher implementations.
AbstractLauncher() - Constructor for class org.springframework.yarn.am.container.AbstractLauncher
 
AbstractLauncher.ContainerLauncherInterceptorList - Class in org.springframework.yarn.am.container
Convenient wrapper for interceptor list.
AbstractLauncher.ContainerLauncherInterceptorList() - Constructor for class org.springframework.yarn.am.container.AbstractLauncher.ContainerLauncherInterceptorList
 
AbstractMonitor - Class in org.springframework.yarn.am.monitor
The base class for Container monitoring implementations.
AbstractMonitor() - Constructor for class org.springframework.yarn.am.monitor.AbstractMonitor
 
AbstractPollingAllocator - Class in org.springframework.yarn.am.allocate
Base implementation of allocator which is meant to handle allocation by doing a simple periodic polling against resource manager.
AbstractPollingAllocator() - Constructor for class org.springframework.yarn.am.allocate.AbstractPollingAllocator
 
AbstractProcessingAppmaster - Class in org.springframework.yarn.am
Base application master implementation which handles a simple life-cycle scenario of; allocate, launch, monitor.
AbstractProcessingAppmaster() - Constructor for class org.springframework.yarn.am.AbstractProcessingAppmaster
 
AbstractServicesAppmaster - Class in org.springframework.yarn.am
Extension of AbstractAppmaster which adds a common container services needed for usual application master.
AbstractServicesAppmaster() - Constructor for class org.springframework.yarn.am.AbstractServicesAppmaster
 
AbstractYarnClient - Class in org.springframework.yarn.client
Base implementation providing functionality for YarnClient.
AbstractYarnClient(ClientRmOperations) - Constructor for class org.springframework.yarn.client.AbstractYarnClient
Constructs client with a given template.
AbstractYarnContainer - Class in org.springframework.yarn.container
Base implementation of YarnContainer providing some common functionality like environment properties, command line parameters and handling of the AbstractYarnContainer.run().
AbstractYarnContainer() - Constructor for class org.springframework.yarn.container.AbstractYarnContainer
 
AbstractYarnEvent - Class in org.springframework.yarn.event
Base ApplicationEvent class for Yarn based events.
AbstractYarnEvent(Object) - Constructor for class org.springframework.yarn.event.AbstractYarnEvent
Create a new ApplicationEvent.
AbstractYarnNamespaceHandler - Class in org.springframework.yarn.config
Base namespace handler which registers a bean factory post processor order to get default beans created automatically.
AbstractYarnNamespaceHandler() - Constructor for class org.springframework.yarn.config.AbstractYarnNamespaceHandler
 
add(ContainerLauncherInterceptor) - Method in class org.springframework.yarn.am.container.AbstractLauncher.ContainerLauncherInterceptorList
Adds interceptor to the list.
add(S) - Method in class org.springframework.yarn.listener.OrderedComposite
Register additional item.
addAny(int) - Method in class org.springframework.yarn.am.allocate.ContainerAllocateData
Adds request for any container for given count.
addAppmasterStateListener(AppmasterStateListener) - Method in class org.springframework.yarn.am.AbstractAppmaster
Adds the appmaster state listener.
addAppmasterStateListener(AppmasterStateListener) - Method in interface org.springframework.yarn.am.YarnAppmaster
Adds the appmaster state listener.
addArchives(Configuration, Resource...) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
 
addContainerMonitorStateListener(ContainerMonitorListener) - Method in class org.springframework.yarn.am.monitor.AbstractMonitor
Adds the container monitor state listener.
addContainerMonitorStateListener(ContainerMonitorListener) - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Adds the container monitor state listener.
addContainers(int) - Method in class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
Adds new count of containers into 'any' pending requests.
addContainers(ContainerAllocateData) - Method in class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
Adds new count of containers into 'host', 'rack' and 'any' pending requests.
addContainerStateListener(ContainerStateListener) - Method in class org.springframework.yarn.container.AbstractYarnContainer
 
addContainerStateListener(ContainerStateListener) - Method in interface org.springframework.yarn.container.LongRunningYarnContainer
Adds the container state listener.
addExitDescription(String) - Method in class org.springframework.yarn.launch.ExitStatus
Add an exit description to an existing ExitStatus.
addExitDescription(Throwable) - Method in class org.springframework.yarn.launch.ExitStatus
Extract the stack trace from the throwable provided and append it to the exist description.
addFiles(Configuration, Resource...) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
 
addHeader(Integer, TableHeader) - Method in class org.springframework.yarn.support.console.Table
 
addHosts(String, int) - Method in class org.springframework.yarn.am.allocate.ContainerAllocateData
Adds request for a host for given count.
addInterceptor(ContainerLauncherInterceptor) - Method in class org.springframework.yarn.am.container.AbstractLauncher
Add a service interceptor to the end of the list.
addLibs(Configuration, Resource...) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
 
addListener(ContainerAllocatorListener) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator
Adds the ContainerAllocatorListener.
addListener(ContainerAllocatorListener) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
addProperties(Configuration, Properties) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
Adds the specified properties to the given Configuration object.
addRacks(String, int) - Method in class org.springframework.yarn.am.allocate.ContainerAllocateData
Adds request for a rack for given count.
addValue(Integer, String) - Method in class org.springframework.yarn.support.console.TableRow
Add a value to the to the specified column within this row.
afterPropertiesSet() - Method in class org.springframework.yarn.client.AbstractYarnClient
 
afterPropertiesSet() - Method in class org.springframework.yarn.client.YarnClientFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.container.YarnContainerFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
 
afterPropertiesSet() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
allocate(AllocateRequest) - Method in interface org.springframework.yarn.am.AppmasterRmOperations
Allocate container.
allocate(AllocateRequest) - Method in class org.springframework.yarn.am.AppmasterRmTemplate
 
allocateContainers(int) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator
Allocate new containers.
allocateContainers(ContainerAllocateData) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator
Allocate new containers.
allocateContainers(int) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
allocateContainers(ContainerAllocateData) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
allocated(List<Container>) - Method in class org.springframework.yarn.listener.CompositeContainerAllocatorListener
 
allocated(List<Container>) - Method in interface org.springframework.yarn.listener.ContainerAllocatorListener
Invoked when new containers are allocated.
AMSERVICE_BATCH_JOBEXECUTIONID - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for amservice batch job execution id.
AMSERVICE_BATCH_STEPEXECUTIONID - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for amservice batch step execution id.
AMSERVICE_BATCH_STEPNAME - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for amservice batch step name.
AMSERVICE_HOST - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for amservice host.
AMSERVICE_PORT - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for amservice port.
and(ExitStatus) - Method in class org.springframework.yarn.launch.ExitStatus
Create a new ExitStatus with a logical combination of the exit code, and a concatenation of the descriptions.
AppmasterCmOperations - Interface in org.springframework.yarn.am
Interface for appmaster to container manager communication.
AppmasterCmTemplate - Class in org.springframework.yarn.am
Template implementation for AppmasterCmOperations wrapping communication using ContainerManagementProtocol.
AppmasterCmTemplate(Configuration, Container) - Constructor for class org.springframework.yarn.am.AppmasterCmTemplate
Instantiates a new AppmasterCmTemplate.
AppmasterConstants - Class in org.springframework.yarn.am
Public constants used for application master.
AppmasterConstants() - Constructor for class org.springframework.yarn.am.AppmasterConstants
 
AppmasterRmOperations - Interface in org.springframework.yarn.am
Interface for appmaster to resource manager communication.
AppmasterRmTemplate - Class in org.springframework.yarn.am
Template implementation for AppmasterRmOperations wrapping communication using ApplicationMasterProtocol.
AppmasterRmTemplate(Configuration) - Constructor for class org.springframework.yarn.am.AppmasterRmTemplate
Instantiates a new AppmasterRmTemplate.
AppmasterScOperations - Interface in org.springframework.yarn.client
Interface defining message operations for Application Master Service Client.
AppmasterService - Interface in org.springframework.yarn.am
Interface for service running on Application Master.
AppmasterServiceClient - Interface in org.springframework.yarn.am
Currently this is empty and only used as marker interface making indication that a class is used client for Application Master Service.
AppmasterStateListener - Interface in org.springframework.yarn.listener
Interface used for appmaster to notify its state.
AppmasterStateListener.AppmasterState - Enum in org.springframework.yarn.listener
Enum for appmaster states
AppmasterTrackService - Interface in org.springframework.yarn.am
Generic interface for Hadoop Yarn Track Service running inside Application Master.
ARG_APPLICATION_ID - Static variable in class org.springframework.yarn.client.CommandLineClientRunner
 
asProperties(Configuration) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
Returns a static Properties copy of the given configuration.
assign(ContainerId, E) - Method in interface org.springframework.yarn.am.assign.ContainerAssign
Assign data with container.
assign(ContainerId, Object) - Method in class org.springframework.yarn.am.assign.DefaultContainerAssign
 

C

calculateColumnWidths() - Method in class org.springframework.yarn.support.console.Table
 
clean() - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
 
clean() - Method in interface org.springframework.yarn.fs.ResourceLocalizer
Cleans all leftovers what has been created during the distribute process.
ClientParser - Class in org.springframework.yarn.config
Simple namespace parser for yarn:client.
ClientParser() - Constructor for class org.springframework.yarn.config.ClientParser
 
ClientRmOperations - Interface in org.springframework.yarn.client
Interface for client to resource manager communication.
ClientRmTemplate - Class in org.springframework.yarn.client
Template implementation for ClientRmOperations wrapping communication using ApplicationClientProtocol.
ClientRmTemplate(Configuration) - Constructor for class org.springframework.yarn.client.ClientRmTemplate
Constructs a ClientRmTemplate with a given yarn configuration.
closeReader(Reader) - Static method in class org.springframework.yarn.support.console.CommonUtils
 
collectionToCommaDelimitedString(Collection<String>) - Static method in class org.springframework.yarn.support.console.CommonUtils
Convert a List of Strings to a comma delimited String.
COLUMN_1 - Static variable in class org.springframework.yarn.support.console.UiUtils
 
COLUMN_2 - Static variable in class org.springframework.yarn.support.console.UiUtils
 
COLUMN_3 - Static variable in class org.springframework.yarn.support.console.UiUtils
 
COLUMN_4 - Static variable in class org.springframework.yarn.support.console.UiUtils
 
COLUMN_5 - Static variable in class org.springframework.yarn.support.console.UiUtils
 
COLUMN_6 - Static variable in class org.springframework.yarn.support.console.UiUtils
 
CommandLineAppmasterRunner - Class in org.springframework.yarn.am
Simple launcher for application master.
CommandLineAppmasterRunner() - Constructor for class org.springframework.yarn.am.CommandLineAppmasterRunner
 
CommandLineClientRunner - Class in org.springframework.yarn.client
A simple client runner executing a bean named "yarnClient".
CommandLineClientRunner() - Constructor for class org.springframework.yarn.client.CommandLineClientRunner
 
CommandLineContainerRunner - Class in org.springframework.yarn.container
A simple container runner executing a bean named "yarnContainer".
CommandLineContainerRunner() - Constructor for class org.springframework.yarn.container.CommandLineContainerRunner
 
CommandYarnClient - Class in org.springframework.yarn.client
Default Yarn client utilising functionality in AbstractYarnClient.
CommandYarnClient(ClientRmOperations) - Constructor for class org.springframework.yarn.client.CommandYarnClient
Constructs a default client with a given template.
CommonUtils - Class in org.springframework.yarn.support.console
Contains common non-ui related helper methods for rendering text to the console.
CommonUtils() - Constructor for class org.springframework.yarn.support.console.CommonUtils
 
compareTo(ExitStatus) - Method in class org.springframework.yarn.launch.ExitStatus
 
COMPLETED - Static variable in class org.springframework.yarn.launch.ExitStatus
Convenient constant value representing finished processing.
completed(List<ContainerStatus>) - Method in class org.springframework.yarn.listener.CompositeContainerAllocatorListener
 
completed(List<ContainerStatus>) - Method in interface org.springframework.yarn.listener.ContainerAllocatorListener
Invoked when containers are releases and thus marked as completed.
completedCount() - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Gets a count of completed containers.
completedCount() - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 
CompositeAppmasterStateListener - Class in org.springframework.yarn.listener
Composite listener for handling appmaster state events.
CompositeAppmasterStateListener() - Constructor for class org.springframework.yarn.listener.CompositeAppmasterStateListener
 
CompositeContainerAllocatorListener - Class in org.springframework.yarn.listener
Composite listener for handling allocation events.
CompositeContainerAllocatorListener() - Constructor for class org.springframework.yarn.listener.CompositeContainerAllocatorListener
 
CompositeContainerMonitorStateListener - Class in org.springframework.yarn.listener
Composite listener for handling container monitor events.
CompositeContainerMonitorStateListener() - Constructor for class org.springframework.yarn.listener.CompositeContainerMonitorStateListener
 
CompositeContainerStateListener - Class in org.springframework.yarn.listener
Composite listener for handling container state events.
CompositeContainerStateListener() - Constructor for class org.springframework.yarn.listener.CompositeContainerStateListener
 
ConfigurationFactoryBean - Class in org.springframework.yarn.configuration
FactoryBean for creating YarnConfiguration instances.
ConfigurationFactoryBean() - Constructor for class org.springframework.yarn.configuration.ConfigurationFactoryBean
 
ConfigurationUtils - Class in org.springframework.yarn.configuration
Reusable utility class for common Configuration operations.
ConfigurationUtils() - Constructor for class org.springframework.yarn.configuration.ConfigurationUtils
 
ConfiguringBeanFactoryPostProcessor - Class in org.springframework.yarn.config
Bean factory post processor which adds creates default task scheduler and executor if necessary.
ConfiguringBeanFactoryPostProcessor() - Constructor for class org.springframework.yarn.config.ConfiguringBeanFactoryPostProcessor
 
CONTAINER_COUNT - Static variable in class org.springframework.yarn.am.AppmasterConstants
Constant used to indicate number of container launched
ContainerAllocateData - Class in org.springframework.yarn.am.allocate
Acts as a main entry point abstracting access for ResourceRequests.
ContainerAllocateData() - Constructor for class org.springframework.yarn.am.allocate.ContainerAllocateData
Instantiates a new container allocate data.
ContainerAllocationEvent - Class in org.springframework.yarn.event
Generic event representing that Container has been allocated.
ContainerAllocationEvent(Object, Container) - Constructor for class org.springframework.yarn.event.ContainerAllocationEvent
Constructs event with the given Container.
ContainerAllocator - Interface in org.springframework.yarn.am.allocate
General interface for container allocators.
ContainerAllocatorListener - Interface in org.springframework.yarn.listener
Interface used for allocator to notify newly allocated and completed containers.
ContainerAssign<E> - Interface in org.springframework.yarn.am.assign
Interface storing and keeping data associated with a container.
ContainerCompletedEvent - Class in org.springframework.yarn.event
Generic event representing that Container has been completed.
ContainerCompletedEvent(Object, ContainerStatus) - Constructor for class org.springframework.yarn.event.ContainerCompletedEvent
Constructs event with the given ContainerStatus.
ContainerLaunchedEvent - Class in org.springframework.yarn.event
Generic event representing that Container has been launched.
ContainerLaunchedEvent(Object, Container) - Constructor for class org.springframework.yarn.event.ContainerLaunchedEvent
Constructs event with the given Container.
ContainerLauncher - Interface in org.springframework.yarn.am.container
General interface for container launcher.
ContainerLauncherInterceptor - Interface in org.springframework.yarn.am
Interface for interceptors that are able to view and/or modify the ContainerLaunchContext before the container is launched.
ContainerMonitor - Interface in org.springframework.yarn.am.monitor
General interface for components able to monitor application and container statuses.
ContainerMonitorListener - Interface in org.springframework.yarn.listener
Interface used for monitor to state of the monitor.
ContainerMonitorListener.ContainerMonitorState - Class in org.springframework.yarn.listener
Class holding state info.
ContainerMonitorListener.ContainerMonitorState(int, int, int, double) - Constructor for class org.springframework.yarn.listener.ContainerMonitorListener.ContainerMonitorState
Instantiates a new container monitor state.
ContainerParser - Class in org.springframework.yarn.config
Simple namespace parser for yarn:container.
ContainerParser() - Constructor for class org.springframework.yarn.config.ContainerParser
 
ContainerRequestHint - Class in org.springframework.yarn.am.container
Helper class used to add request data hints.
ContainerRequestHint(Object, Resource, String[], String[], Priority) - Constructor for class org.springframework.yarn.am.container.ContainerRequestHint
Instantiates a new container request data.
ContainerResolver - Interface in org.springframework.yarn.am.container
Interface for implementations which knows how to resolve container locations.
ContainerStateListener - Interface in org.springframework.yarn.listener
Interface used for container to notify its state.
ContainerStateListener.ContainerState - Enum in org.springframework.yarn.listener
Enum for container states
convertYarnAccessException(YarnRuntimeException) - Static method in class org.springframework.yarn.support.YarnUtils
Converts YarnRuntimeException to a Spring dao exception.
convertYarnAccessException(IOException) - Static method in class org.springframework.yarn.support.YarnUtils
Converts IOException to a Spring dao exception.
convertYarnAccessException(RemoteException) - Static method in class org.springframework.yarn.support.YarnUtils
Converts RemoteException to a Spring dao exception.
convertYarnAccessException(YarnException) - Static method in class org.springframework.yarn.support.YarnUtils
Converts YarnException to a Spring dao exception.
createConfiguration(Configuration) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Creates a configuration instance potentially using the existing one (passed as an argument - which can be null).
createElementDescription(Element) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Provides a user friendly description of an element based on its node name and, if available, its "id" attribute value.
createEnvironment() - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
Creates the Map to be returned from this factory bean.
createFrom(Configuration, Properties) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
Creates a new Configuration based on the given arguments.
createFrom(YarnConfiguration, Properties) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
Creates a new YarnConfiguration based on the given arguments.
createProxy() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
Creates the proxy.

D

DEFAULT_CONTEXT_FILE_APPMASTER - Static variable in class org.springframework.yarn.YarnSystemConstants
Default name of appmaster context file.
DEFAULT_CONTEXT_FILE_CLIENT - Static variable in class org.springframework.yarn.YarnSystemConstants
Default name of client context file.
DEFAULT_CONTEXT_FILE_CONTAINER - Static variable in class org.springframework.yarn.YarnSystemConstants
Default name of container context file.
DEFAULT_ID_AMSERVICE - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for appmaster service.
DEFAULT_ID_AMSERVICE_CLIENT - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for appmaster service client.
DEFAULT_ID_AMTRACKSERVICE - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for appmaster track service.
DEFAULT_ID_APPMASTER - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for appmaster.
DEFAULT_ID_CLIENT - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for client.
DEFAULT_ID_CLIENT_AMSERVICE - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for appmaster client service.
DEFAULT_ID_CONFIGURATION - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for resource yarn configuration.
DEFAULT_ID_CONTAINER - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for container.
DEFAULT_ID_ENVIRONMENT - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for resource environment.
DEFAULT_ID_EVENT_PUBLISHER - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for Yarn event publisher.
DEFAULT_ID_LOCAL_RESOURCES - Static variable in class org.springframework.yarn.YarnSystemConstants
Default bean id for resource localizer.
DEFAULT_STAGING_BASE_DIR_NAME - Static variable in class org.springframework.yarn.YarnSystemConstants
Default staging directory base name.
DEFAULT_STAGING_DIR_NAME - Static variable in class org.springframework.yarn.YarnSystemConstants
Default staging directory name.
DefaultAllocateCountTracker - Class in org.springframework.yarn.am.allocate
Helper class tracking allocation counts.
DefaultAllocateCountTracker() - Constructor for class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
 
DefaultContainerAllocator - Class in org.springframework.yarn.am.allocate
Default allocator which polls resource manager, requests new containers and acts as a heart beat sender at the same time.
DefaultContainerAllocator() - Constructor for class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
DefaultContainerAssign - Class in org.springframework.yarn.am.assign
Default ContainerAssign implementation using Objects as assigned data.
DefaultContainerAssign() - Constructor for class org.springframework.yarn.am.assign.DefaultContainerAssign
 
DefaultContainerLauncher - Class in org.springframework.yarn.am.container
Default container launcher.
DefaultContainerLauncher() - Constructor for class org.springframework.yarn.am.container.DefaultContainerLauncher
 
DefaultContainerMonitor - Class in org.springframework.yarn.am.monitor
Default implementation of ContainerMonitor which simple tracks number of total and completed containers.
DefaultContainerMonitor() - Constructor for class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 
defaultId(ParserContext, Element) - Method in class org.springframework.yarn.config.LocalresourcesParser
 
DefaultResourceLocalizer - Class in org.springframework.yarn.fs
Default implementation of ResourceLocalizer which is only capable of re-using files already in HDFS and preparing correct parameters for created LocalResource entries.
DefaultResourceLocalizer(Configuration, Collection<LocalResourcesFactoryBean.TransferEntry>, Collection<LocalResourcesFactoryBean.CopyEntry>) - Constructor for class org.springframework.yarn.fs.DefaultResourceLocalizer
Instantiates a new default resource localizer.
DefaultResourceLocalizer(Configuration, Collection<LocalResourcesFactoryBean.TransferEntry>, Collection<LocalResourcesFactoryBean.CopyEntry>, Path) - Constructor for class org.springframework.yarn.fs.DefaultResourceLocalizer
Instantiates a new default resource localizer.
DefaultYarnEventPublisher - Class in org.springframework.yarn.event
The default strategy for publishing Yarn events.
DefaultYarnEventPublisher() - Constructor for class org.springframework.yarn.event.DefaultYarnEventPublisher
Constructs default strategy without an event publisher.
DefaultYarnEventPublisher(ApplicationEventPublisher) - Constructor for class org.springframework.yarn.event.DefaultYarnEventPublisher
Constructs default strategy with an event publisher.
destroy() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
 
distribute() - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
 
distribute() - Method in interface org.springframework.yarn.fs.ResourceLocalizer
If underlying implementation needs to do operations on hdfs filesystem or any other preparation work, calling of this method should make implementation ready to return resources from ResourceLocalizer.getResources() command.
doContainerRequest() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
Subclasses needs to implements this method to do container requests against resource manager.
doContainerRequest() - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
doFileCopy(FileSystem) - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
Do file copy.
doFileTransfer(FileSystem) - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
Gets a map of localized resources.
doInYarn(P) - Method in interface org.springframework.yarn.rpc.YarnRpcCallback
Execute callback.
doMain(String[]) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Main method visible to sub-classes.
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.config.ClientParser
 
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.config.ContainerParser
 
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.yarn.config.LocalresourcesParser
 
doStart() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
 
doStart() - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher
 
doStart() - Method in class org.springframework.yarn.am.StaticAppmaster
 
doStart() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Subclasses may implement this method with the start behavior.
doStop() - Method in class org.springframework.yarn.am.AbstractAppmaster
 
doStop() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
 
doStop() - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher
 
doStop() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Subclasses may implement this method with the stop behavior.

E

EnvironmentFactoryBean - Class in org.springframework.yarn.configuration
FactoryBean for creating a Map of environment variables.
EnvironmentFactoryBean() - Constructor for class org.springframework.yarn.configuration.EnvironmentFactoryBean
 
equals(Object) - Method in class org.springframework.yarn.launch.ExitStatus
Compare the fields one by one.
equals(Object) - Method in class org.springframework.yarn.support.console.TableRow
 
execute(YarnRpcCallback<T, S>) - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
Execute given action callback on the rpc proxy.
EXECUTING - Static variable in class org.springframework.yarn.launch.ExitStatus
Convenient constant value representing continuable state where processing is still taking place, so no further action is required.
exit(int) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Exit method wrapping handling through SystemExiter.
exit(int) - Method in class org.springframework.yarn.launch.JvmSystemExiter
Delegate call to System.exit() with the argument provided.
exit(int) - Method in interface org.springframework.yarn.launch.SystemExiter
Terminate the currently running Java Virtual Machine.
ExitCodeMapper - Interface in org.springframework.yarn.launch
This interface should be implemented when an environment calling the batch framework has specific requirements regarding the operating system process return status.
ExitStatus - Class in org.springframework.yarn.launch
Value object used to carry information about the status of a job or step execution.
ExitStatus(String) - Constructor for class org.springframework.yarn.launch.ExitStatus
 
ExitStatus(String, String) - Constructor for class org.springframework.yarn.launch.ExitStatus
 
extractClasspath(String, String) - Static method in class org.springframework.yarn.support.ParsingUtils
Extracts a classpath string from a source text.
extractRunnableCommand(String) - Static method in class org.springframework.yarn.support.ParsingUtils
Extracts a string from another string which can be used as a command in shell.

F

FAILED - Static variable in class org.springframework.yarn.launch.ExitStatus
Convenient constant value representing finished processing with an error.
failedCount() - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Gets a count of failed containers.
failedCount() - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 
finish(FinishApplicationMasterRequest) - Method in interface org.springframework.yarn.am.AppmasterRmOperations
Finish the application master.
finish(FinishApplicationMasterRequest) - Method in class org.springframework.yarn.am.AppmasterRmTemplate
 
finishAppmaster() - Method in class org.springframework.yarn.am.AbstractAppmaster
Finish appmaster by sending request to resource manager.
freeCount() - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Gets a count of free containers.
freeCount() - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 
FS_ADDRESS - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for hdfs address.

G

GenericRpcMessage<T> - Class in org.springframework.yarn.am
Generic RpcMessage implementation.
GenericRpcMessage(T) - Constructor for class org.springframework.yarn.am.GenericRpcMessage
Constructs a GenericRpcMessage with a given body.
get(RpcMessage<?>) - Method in interface org.springframework.yarn.client.AppmasterScOperations
Sends request wrapped in RpcMessage and receives response similarly wrapped in RpcMessage.
getAddress(Configuration) - Static method in class org.springframework.yarn.support.YarnUtils
Gets the address.
getAllocateCounts() - Method in class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
Gets the allocate counts which should be used to create allocate requests.
getAllocated() - Method in class org.springframework.yarn.listener.ContainerMonitorListener.ContainerMonitorState
Gets the allocated.
getAllocator() - Method in class org.springframework.yarn.am.AbstractServicesAppmaster
Gets a used ContainerAllocator for this class.
getAny() - Method in class org.springframework.yarn.am.allocate.ContainerAllocateData
Gets the count for any container.
getApplicationAttemptId() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the application attempt id.
getApplicationAttemptId() - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Gets the application attempt id.
getApplicationAttemptId(Map<String, String>) - Static method in class org.springframework.yarn.support.YarnUtils
Gets ApplicationAttemptId from environment variables.
getApplicationContext(String) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Gets the Application Context.
getApplicationReport(ApplicationId) - Method in class org.springframework.yarn.client.AbstractYarnClient
 
getApplicationReport(ApplicationId) - Method in interface org.springframework.yarn.client.ClientRmOperations
Gets a report of the application.
getApplicationReport(ApplicationId) - Method in class org.springframework.yarn.client.ClientRmTemplate
 
getApplicationReport(ApplicationId) - Method in interface org.springframework.yarn.client.YarnClient
Gets a report of the application.
getAppmasterClientService() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets a client facing AppmasterService set to this instance.
getAppmasterClientService(BeanFactory) - Static method in class org.springframework.yarn.support.YarnContextUtils
Return the AppmasterService bean whose name is "yarnClientAmservice" if available.
getAppmasterService() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets a AppmasterService set to this instance.
getAppmasterService(BeanFactory) - Static method in class org.springframework.yarn.support.YarnContextUtils
Return the AppmasterService bean whose name is "yarnAmservice" if available.
getAppmasterTrackService() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets a AppmasterTrackService set to this instance.
getAppmasterTrackService(BeanFactory) - Static method in class org.springframework.yarn.support.YarnContextUtils
Return the AppmasterTrackService bean whose name is "yarnAmTrackservice" if available.
getAssignedContainer(E) - Method in interface org.springframework.yarn.am.assign.ContainerAssign
Gets the assigned container.
getAssignedContainer(Object) - Method in class org.springframework.yarn.am.assign.DefaultContainerAssign
 
getAssignedData(ContainerId) - Method in interface org.springframework.yarn.am.assign.ContainerAssign
Gets the assigned data.
getAssignedData(ContainerId) - Method in class org.springframework.yarn.am.assign.DefaultContainerAssign
 
getBeanClass(Element) - Method in class org.springframework.yarn.config.ClientParser
 
getBeanClass(Element) - Method in class org.springframework.yarn.config.ContainerParser
 
getBeanClass(Element) - Method in class org.springframework.yarn.config.LocalresourcesParser
 
getBeanFactory() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Gets the BeanFactory for this instance.
getBody() - Method in class org.springframework.yarn.am.GenericRpcMessage
 
getBody() - Method in interface org.springframework.yarn.am.RpcMessage
Gets a body of this message.
getCapability() - Method in class org.springframework.yarn.am.container.ContainerRequestHint
Gets the capability.
getChildApplicationContext(String, ConfigurableApplicationContext) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Gets the Application Context.
getChildContextConfigPath(String) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Allows subclass to modify parsed context configuration path.
getClientRmOperations() - Method in class org.springframework.yarn.client.AbstractYarnClient
Gets the client rm operations.
getCmTemplate(Container) - Method in class org.springframework.yarn.am.container.AbstractLauncher
Constructs a new AppmasterCmOperations template.
getCommands() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the commands.
getCompleted() - Method in class org.springframework.yarn.listener.ContainerMonitorListener.ContainerMonitorState
Gets the completed.
getConfiguration() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the Yarn configuration.
getConfiguration() - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Gets the Yarn configuration.
getConfiguration() - Method in class org.springframework.yarn.am.container.AbstractLauncher
Gets the Yarn configuration.
getConfiguration() - Method in class org.springframework.yarn.client.AbstractYarnClient
Get the Configuration of this client.
getConfiguration() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
Gets the Yarn configuration.
getContainer() - Method in class org.springframework.yarn.event.ContainerAllocationEvent
Gets the container.
getContainer() - Method in class org.springframework.yarn.event.ContainerLaunchedEvent
Gets the container.
getContainerAssign() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the container assign.
getContainerStatus() - Method in interface org.springframework.yarn.am.AppmasterCmOperations
Gets the container status.
getContainerStatus() - Method in class org.springframework.yarn.am.AppmasterCmTemplate
 
getContainerStatus() - Method in class org.springframework.yarn.event.ContainerCompletedEvent
Gets the container status.
getContextConfigPath(String) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Allows subclass to modify parsed context configuration path.
getDefaultAddress() - Static method in class org.springframework.yarn.support.NetworkUtils
Gets the main network address.
getDefaultBeanIdentifier() - Method in class org.springframework.yarn.am.CommandLineAppmasterRunner
 
getDefaultBeanIdentifier() - Method in class org.springframework.yarn.client.CommandLineClientRunner
 
getDefaultBeanIdentifier() - Method in class org.springframework.yarn.container.CommandLineContainerRunner
 
getDefaultBeanIdentifier() - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Gets a default bean id which is used to resolve the instance from an Application Context.
getDelegationToken(String) - Method in interface org.springframework.yarn.client.ClientRmOperations
Gets the resource manager delegation token.
getDelegationToken(String) - Method in class org.springframework.yarn.client.ClientRmTemplate
 
getEnvironment() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the environment variables.
getEnvironment() - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Gets the environment.
getEnvironment() - Method in class org.springframework.yarn.am.container.AbstractLauncher
Gets the environment.
getEnvironment() - Method in class org.springframework.yarn.client.AbstractYarnClient
Gets the environment variables.
getEnvironment() - Method in class org.springframework.yarn.client.CommandYarnClient
 
getEnvironment(String) - Method in class org.springframework.yarn.container.AbstractYarnContainer
Gets the environment variable.
getEnvironment() - Method in class org.springframework.yarn.container.AbstractYarnContainer
Gets the environment.
getErrorMessage() - Static method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Gets the static error message set for this class.
getEventPublisher(BeanFactory) - Static method in class org.springframework.yarn.support.YarnContextUtils
Return the YarnEventPublisher bean whose name is "yarnEventPublisher" if available.
getExitCode() - Method in class org.springframework.yarn.launch.ExitStatus
Getter for the exit code (defaults to blank).
getExitDescription() - Method in class org.springframework.yarn.launch.ExitStatus
Getter for the exit description (defaults to blank)
getFailed() - Method in class org.springframework.yarn.listener.ContainerMonitorListener.ContainerMonitorState
Gets the failed.
getHeaderBorder(Map<Integer, TableHeader>) - Static method in class org.springframework.yarn.support.console.UiUtils
Renders the Table header border, based on the map of provided headers.
getHeaders() - Method in class org.springframework.yarn.support.console.Table
 
getHost() - Method in interface org.springframework.yarn.am.AppmasterService
Get a hostname where service is running.
getHosts() - Method in class org.springframework.yarn.am.allocate.ContainerAllocateData
Gets the hosts counts.
getHosts() - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Gets the hosts.
getHosts() - Method in class org.springframework.yarn.am.container.ContainerRequestHint
Gets the hosts.
getId() - Method in class org.springframework.yarn.am.container.ContainerRequestHint
Gets the id.
getInterceptors() - Method in class org.springframework.yarn.am.container.AbstractLauncher
Exposes the interceptor list for subclasses.
getLauncher() - Method in class org.springframework.yarn.am.AbstractServicesAppmaster
Gets a used ContainerLauncher for this class.
getListeners() - Method in class org.springframework.yarn.listener.AbstractCompositeListener
Gets the listeners.
getMapping() - Method in class org.springframework.yarn.launch.SimpleJvmExitCodeMapper
 
getMasterContainerLaunchContext() - Method in class org.springframework.yarn.client.AbstractYarnClient
Gets the master container launch context.
getMaxWidth() - Method in class org.springframework.yarn.support.console.TableHeader
 
getMemory() - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Gets the memory for container request.
getMonitor() - Method in class org.springframework.yarn.am.AbstractServicesAppmaster
Gets a used ContainerMonitor for this class.
getName() - Method in class org.springframework.yarn.support.console.TableHeader
 
getNewApplication() - Method in interface org.springframework.yarn.client.ClientRmOperations
Requests a new application from a resource manager.
getNewApplication() - Method in class org.springframework.yarn.client.ClientRmTemplate
 
getNMTokenCache() - Static method in class org.springframework.yarn.support.compat.NMTokenCacheCompat
Gets the Hadoop NMTokenCache.
getObject() - Method in class org.springframework.yarn.client.YarnClientFactoryBean
 
getObject() - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
 
getObject() - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
 
getObject() - Method in class org.springframework.yarn.container.YarnContainerFactoryBean
 
getObject() - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
 
getObject() - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.client.YarnClientFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.container.YarnContainerFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
 
getObjectType() - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
 
getParameters() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the parameters.
getParameters() - Method in class org.springframework.yarn.container.AbstractYarnContainer
Gets the parameters.
getPhase() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
getPort() - Method in interface org.springframework.yarn.am.AppmasterService
Get a port where service is running.
getPrincipal(Configuration) - Static method in class org.springframework.yarn.support.YarnUtils
Gets the principal.
getPriority() - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Gets the priority for container request.
getPriority() - Method in class org.springframework.yarn.am.container.ContainerRequestHint
Gets the priority.
getProgress() - Method in class org.springframework.yarn.listener.ContainerMonitorListener.ContainerMonitorState
Gets the progress.
getProxy() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
Gets the proxy handled by this accessor.
getRacks() - Method in class org.springframework.yarn.am.allocate.ContainerAllocateData
Gets the racks counts.
getRacks() - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Gets the racks.
getRacks() - Method in class org.springframework.yarn.am.container.ContainerRequestHint
Gets the racks.
getResourceLocalizer() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the resource localizer.
getResourceLocalizer() - Method in class org.springframework.yarn.am.container.AbstractLauncher
Gets the resource localizer.
getResources() - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
 
getResources() - Method in interface org.springframework.yarn.fs.ResourceLocalizer
Gets a map of LocalResource instances.
getRmTemplate() - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Gets the rm template.
getRows() - Method in class org.springframework.yarn.support.console.Table
 
getRpcAddress(Configuration) - Method in class org.springframework.yarn.am.AppmasterCmTemplate
 
getRpcAddress(Configuration) - Method in class org.springframework.yarn.am.AppmasterRmTemplate
 
getRpcAddress(Configuration) - Method in class org.springframework.yarn.client.ClientRmTemplate
 
getRpcAddress(Configuration) - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
Gets the InetSocketAddress where this accessor should connect.
getStagingPath() - Method in class org.springframework.yarn.client.AbstractYarnClient
Gets the staging path.
getSubmissionContext(ApplicationId) - Method in class org.springframework.yarn.client.AbstractYarnClient
Gets the submission context for application master.
getTaskExecutor() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Gets the defined TaskExecutor.
getTaskExecutor(BeanFactory) - Static method in class org.springframework.yarn.support.YarnContextUtils
Return the TaskScheduler bean whose name is "taskExecutor" if available.
getTaskScheduler() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Gets the defined TaskScheduler.
getTaskScheduler(BeanFactory) - Static method in class org.springframework.yarn.support.YarnContextUtils
Return the TaskScheduler bean whose name is "taskScheduler" if available.
getTemplate() - Method in class org.springframework.yarn.am.AbstractAppmaster
Gets the AppmasterRmOperations template.
getTrackUrl() - Method in interface org.springframework.yarn.am.AppmasterTrackService
Gets a url of this track service.
getTrackUrl() - Method in class org.springframework.yarn.am.track.UrlAppmasterTrackService
 
getUser() - Method in class org.springframework.yarn.am.AppmasterCmTemplate
 
getUser() - Method in class org.springframework.yarn.rpc.YarnRpcAccessor
Gets the user used to create the proxy.
getUsername() - Method in class org.springframework.yarn.am.container.AbstractLauncher
Gets the username for launch context.
getUserName(Configuration) - Static method in class org.springframework.yarn.support.YarnUtils
Gets the user name.
getValidOpts() - Method in class org.springframework.yarn.am.CommandLineAppmasterRunner
 
getValidOpts() - Method in class org.springframework.yarn.client.CommandLineClientRunner
 
getValidOpts() - Method in class org.springframework.yarn.container.CommandLineContainerRunner
 
getValidOpts() - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Gets the list of valid option arguments.
getValue(Integer) - Method in class org.springframework.yarn.support.console.TableRow
Return a value from this row.
getVirtualcores() - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Gets the virtualcores for container request.
getWidth() - Method in class org.springframework.yarn.support.console.TableHeader
 
getYarnEventPublisher() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Gets the yarn event publisher.

H

handleAllocatedContainers(List<Container>) - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
Subclasses needs to implement this method to handle newly allocated containers.
handleAllocatedContainers(List<Container>) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
handleBeanRun(YarnAppmaster, String[], Set<String>) - Method in class org.springframework.yarn.am.CommandLineAppmasterRunner
 
handleBeanRun(YarnClient, String[], Set<String>) - Method in class org.springframework.yarn.client.CommandLineClientRunner
 
handleBeanRun(YarnContainer, String[], Set<String>) - Method in class org.springframework.yarn.container.CommandLineContainerRunner
 
handleBeanRun(T, String[], Set<String>) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Handles the execution of a bean after Application Context(s) has been initialized.
handleCompletedContainers(List<ContainerStatus>) - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
Subclasses needs to implement this method to handle newly released containers.
handleCompletedContainers(List<ContainerStatus>) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
hashCode() - Method in class org.springframework.yarn.launch.ExitStatus
Compatible with the equals implementation.
hashCode() - Method in class org.springframework.yarn.support.console.TableRow
 
hasPort() - Method in interface org.springframework.yarn.am.AppmasterService
This method should return true if a service will eventually bind to a port.
HORIZONTAL_LINE - Static variable in class org.springframework.yarn.support.console.UiUtils
 

I

init() - Method in class org.springframework.yarn.config.YarnNamespaceHandler
 
intValue(String) - Method in interface org.springframework.yarn.launch.ExitCodeMapper
Convert the exit code from String into an integer that the calling environment as an operating system can interpret as an exit status.
intValue(String) - Method in class org.springframework.yarn.launch.SimpleJvmExitCodeMapper
Get the operating system exit status that matches a certain Batch Framework Exitcode
isAutoStartup() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
isComplete() - Method in class org.springframework.yarn.am.StaticEventingAppmaster
Returns state telling if application is considered as complete.
isRunning() - Method in class org.springframework.yarn.launch.ExitStatus
Check if this status represents a running process.
isRunning() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
isSingleton() - Method in class org.springframework.yarn.client.YarnClientFactoryBean
 
isSingleton() - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
 
isSingleton() - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
 
isSingleton() - Method in class org.springframework.yarn.container.YarnContainerFactoryBean
 
isSingleton() - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
 
isSingleton() - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
 
isValidEmail(String) - Static method in class org.springframework.yarn.support.console.CommonUtils
 
isWaitCompleteState() - Method in class org.springframework.yarn.container.AbstractYarnContainer
 
isWaitCompleteState() - Method in interface org.springframework.yarn.container.LongRunningYarnContainer
Indication for possible handler using this bean whether it should wait COMPLETED state.
iterator() - Method in class org.springframework.yarn.listener.OrderedComposite
Public getter for the list of items.

J

JVM_EXITCODE_COMPLETED - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_FORCE_KILLED - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_GENERIC_ERROR - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_INVALID_CONFIG_FILE - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_INVALID_CONTAINER_EXEC_PERMISSIONS - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_INVALID_CONTAINER_PID - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_INVALID_USER_NAME - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_TERMINATED - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_UNABLE_TO_EXECUTE_CONTAINER_SCRIPT - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JVM_EXITCODE_WRITE_CGROUP_FAILED - Static variable in interface org.springframework.yarn.launch.ExitCodeMapper
 
JvmSystemExiter - Class in org.springframework.yarn.launch
Implementation of the SystemExiter interface that calls the standards System.exit method.
JvmSystemExiter() - Constructor for class org.springframework.yarn.launch.JvmSystemExiter
 

K

killApplication(ApplicationId) - Method in class org.springframework.yarn.client.AbstractYarnClient
 
killApplication(ApplicationId) - Method in interface org.springframework.yarn.client.ClientRmOperations
Requests ResourceManager to abort submitted application.
killApplication(ApplicationId) - Method in class org.springframework.yarn.client.ClientRmTemplate
 
killApplication(ApplicationId) - Method in interface org.springframework.yarn.client.YarnClient
Requests a resource manager to kill the application.

L

LaunchCommandsFactoryBean - Class in org.springframework.yarn.launch
Factory bean helping to construct a command meant to start application master or a container.
LaunchCommandsFactoryBean() - Constructor for class org.springframework.yarn.launch.LaunchCommandsFactoryBean
 
launchContainer(Container, List<String>) - Method in interface org.springframework.yarn.am.container.ContainerLauncher
Launch container Container using given list of commands.
launchContainer(Container, List<String>) - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher
 
LifecycleObjectSupport - Class in org.springframework.yarn.support
Convenient base class for object which needs spring task scheduler, task executor and life cycle handling.
LifecycleObjectSupport() - Constructor for class org.springframework.yarn.support.LifecycleObjectSupport
 
listApplications() - Method in class org.springframework.yarn.client.AbstractYarnClient
 
listApplications() - Method in interface org.springframework.yarn.client.ClientRmOperations
Gets a list of ApplicationReports from a resource manager.
listApplications() - Method in class org.springframework.yarn.client.ClientRmTemplate
 
listApplications() - Method in interface org.springframework.yarn.client.YarnClient
Gets a list of known applications.
LocalResourcesFactoryBean - Class in org.springframework.yarn.fs
Factory bean building ResourceLocalizers objects.
LocalResourcesFactoryBean() - Constructor for class org.springframework.yarn.fs.LocalResourcesFactoryBean
 
LocalResourcesFactoryBean.CopyEntry - Class in org.springframework.yarn.fs
Helper class storing copy entries.
LocalResourcesFactoryBean.CopyEntry(String, String, boolean) - Constructor for class org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry
 
LocalResourcesFactoryBean.TransferEntry - Class in org.springframework.yarn.fs
Helper class storing transfer entries.
LocalResourcesFactoryBean.TransferEntry(LocalResourceType, LocalResourceVisibility, String, String, String, boolean) - Constructor for class org.springframework.yarn.fs.LocalResourcesFactoryBean.TransferEntry
 
LocalresourcesParser - Class in org.springframework.yarn.config
Simple namespace parser for yarn:localresources.
LocalresourcesParser() - Constructor for class org.springframework.yarn.config.LocalresourcesParser
 
log - Static variable in class org.springframework.yarn.launch.SimpleJvmExitCodeMapper
 
LoggingListener - Class in org.springframework.yarn.event
Simple ApplicationListener which logs all events based on AbstractYarnEvent using a log level set during the construction.
LoggingListener() - Constructor for class org.springframework.yarn.event.LoggingListener
Constructs Logger listener with debug level.
LoggingListener(String) - Constructor for class org.springframework.yarn.event.LoggingListener
Constructs Logger listener with given level.
LongRunningYarnContainer - Interface in org.springframework.yarn.container
Extension of YarnContainer indicating that container is intended to be a long running operation.

M

main(String[]) - Static method in class org.springframework.yarn.am.CommandLineAppmasterRunner
 
main(String[]) - Static method in class org.springframework.yarn.client.CommandLineClientRunner
 
main(String[]) - Static method in class org.springframework.yarn.container.CommandLineContainerRunner
 
maskPassword(String) - Static method in class org.springframework.yarn.support.console.CommonUtils
Simple method to replace characters in a String with asterisks to mask the password.
MasterParser - Class in org.springframework.yarn.config
Simple namespace parser for yarn:master.
MasterParser() - Constructor for class org.springframework.yarn.config.MasterParser
 
merge(Configuration, Configuration) - Static method in class org.springframework.yarn.configuration.ConfigurationUtils
Creates a new Configuration by merging the given configurations.

N

NetworkUtils - Class in org.springframework.yarn.support
Various network utilities.
NetworkUtils() - Constructor for class org.springframework.yarn.support.NetworkUtils
 
newRow() - Method in class org.springframework.yarn.support.console.Table
Add a new empty row to the table.
NMTokenCacheCompat - Class in org.springframework.yarn.support.compat
Compat class for NMTokenCache.
NMTokenCacheCompat() - Constructor for class org.springframework.yarn.support.compat.NMTokenCacheCompat
 
NOOP - Static variable in class org.springframework.yarn.launch.ExitStatus
Convenient constant value representing job that did no processing (e.g.
notifyCompleted() - Method in class org.springframework.yarn.am.AbstractAppmaster
Notify completed state to appmaster state listeners.
notifyCompleted() - Method in class org.springframework.yarn.container.AbstractYarnContainer
Notify completed state to container state listeners.
notifyState(ContainerMonitorListener.ContainerMonitorState) - Method in class org.springframework.yarn.am.monitor.AbstractMonitor
Notify new ContainerMonitorListener.ContainerMonitorState for registered listeners.

O

onApplicationEvent(AbstractYarnEvent) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
 
onApplicationEvent(AbstractYarnEvent) - Method in class org.springframework.yarn.event.LoggingListener
 
onContainerAllocated(Container) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
Invoked when ContainerAllocationEvent is received as an application event.
onContainerAllocated(Container) - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster
Called when container has been allocated.
onContainerAllocated(Container) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
 
onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
Invoked when ContainerCompletedEvent is received as an application event.
onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster
Called when container has been completed.
onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
 
onContainerFailed(ContainerStatus) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
Called if completed container has failed.
onContainerLaunched(Container) - Method in class org.springframework.yarn.am.AbstractEventingAppmaster
Invoked when ContainerLaunchedEvent is received as an application event.
onContainerLaunched(Container) - Method in class org.springframework.yarn.am.StaticEventingAppmaster
 
onInit() - Method in class org.springframework.yarn.am.AbstractAppmaster
Global application master instance specific ApplicationAttemptId is build during this init method.
onInit() - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster
 
onInit() - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
 
onInit() - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
 
onInit() - Method in class org.springframework.yarn.am.container.AbstractLauncher
 
onInit() - Method in class org.springframework.yarn.am.container.DefaultContainerLauncher
 
onInit() - Method in class org.springframework.yarn.am.StaticAppmaster
 
onInit() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Subclasses may implement this for initialization logic.
OPT_KILL - Static variable in class org.springframework.yarn.client.CommandLineClientRunner
 
OPT_LIST - Static variable in class org.springframework.yarn.client.CommandLineClientRunner
 
OPT_SUBMIT - Static variable in class org.springframework.yarn.client.CommandLineClientRunner
 
OrderedComposite<S> - Class in org.springframework.yarn.listener
Composite item which can be used in other components which may want to allow automatic and annotation based ordering.
OrderedComposite() - Constructor for class org.springframework.yarn.listener.OrderedComposite
 
org.springframework.yarn - package org.springframework.yarn
 
org.springframework.yarn.am - package org.springframework.yarn.am
 
org.springframework.yarn.am.allocate - package org.springframework.yarn.am.allocate
 
org.springframework.yarn.am.assign - package org.springframework.yarn.am.assign
 
org.springframework.yarn.am.container - package org.springframework.yarn.am.container
 
org.springframework.yarn.am.monitor - package org.springframework.yarn.am.monitor
 
org.springframework.yarn.am.track - package org.springframework.yarn.am.track
 
org.springframework.yarn.client - package org.springframework.yarn.client
 
org.springframework.yarn.config - package org.springframework.yarn.config
 
org.springframework.yarn.configuration - package org.springframework.yarn.configuration
 
org.springframework.yarn.container - package org.springframework.yarn.container
 
org.springframework.yarn.event - package org.springframework.yarn.event
 
org.springframework.yarn.fs - package org.springframework.yarn.fs
 
org.springframework.yarn.launch - package org.springframework.yarn.launch
 
org.springframework.yarn.listener - package org.springframework.yarn.listener
 
org.springframework.yarn.rpc - package org.springframework.yarn.rpc
 
org.springframework.yarn.support - package org.springframework.yarn.support
 
org.springframework.yarn.support.compat - package org.springframework.yarn.support.compat
 
org.springframework.yarn.support.console - package org.springframework.yarn.support.console
 

P

padRight(String, int, char) - Static method in class org.springframework.yarn.support.console.CommonUtils
Right-pad a String with a configurable padding character.
padRight(String, int) - Static method in class org.springframework.yarn.support.console.CommonUtils
Right-pad the provided String with empty spaces.
parse(Element, ParserContext) - Method in class org.springframework.yarn.config.AbstractYarnNamespaceHandler
 
parseInnerHandlerDefinition(Element, ParserContext) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Parses inner bean definition from an dom element.
parseInternal(Element, ParserContext) - Method in class org.springframework.yarn.config.MasterParser
 
ParsingUtils - Class in org.springframework.yarn.support
Various static string and parsing utilities.
ParsingUtils() - Constructor for class org.springframework.yarn.support.ParsingUtils
 
populateNmTokenCache(AllocateResponse) - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
Populate node manager token cache in NMTokenCache.
postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.yarn.config.ConfiguringBeanFactoryPostProcessor
 
preLaunch(Container, ContainerLaunchContext) - Method in class org.springframework.yarn.am.AbstractProcessingAppmaster
 
preLaunch(Container, ContainerLaunchContext) - Method in class org.springframework.yarn.am.container.AbstractLauncher.ContainerLauncherInterceptorList
Handles the pre launch calls.
preLaunch(Container, ContainerLaunchContext) - Method in interface org.springframework.yarn.am.ContainerLauncherInterceptor
Invoked before the ContainerLaunchContext is used to launch the container.
preProcessAllocatedContainers(List<Container>) - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
Pre-process allocated containers.
preProcessAllocatedContainers(List<Container>) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
presetSystemExiter(SystemExiter) - Static method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Sets the SystemExiter.
processAllocatedContainer(Container) - Method in class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
 
publishContainerAllocated(Object, Container) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher
 
publishContainerAllocated(Object, Container) - Method in interface org.springframework.yarn.event.YarnEventPublisher
Publish an application event containing information about the allocated Container.
publishContainerCompleted(Object, ContainerStatus) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher
 
publishContainerCompleted(Object, ContainerStatus) - Method in interface org.springframework.yarn.event.YarnEventPublisher
Publish an application event containing information about the completed ContainerStatus.
publishContainerLaunched(Object, Container) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher
 
publishContainerLaunched(Object, Container) - Method in interface org.springframework.yarn.event.YarnEventPublisher
Publish an application event containing information about the launched Container.
publishEvent(AbstractYarnEvent) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher
 
publishEvent(AbstractYarnEvent) - Method in interface org.springframework.yarn.event.YarnEventPublisher
Publish a general application event of type AbstractYarnEvent.

Q

queryApplicationId(YarnClient, String) - Method in class org.springframework.yarn.client.CommandLineClientRunner
Query application id.

R

register(T) - Method in class org.springframework.yarn.listener.AbstractCompositeListener
Register a new listener.
registerApplicationMaster(String, Integer, String) - Method in interface org.springframework.yarn.am.AppmasterRmOperations
Register application master.
registerApplicationMaster(String, Integer, String) - Method in class org.springframework.yarn.am.AppmasterRmTemplate
 
registerAppmaster() - Method in class org.springframework.yarn.am.AbstractAppmaster
Register appmaster.
releaseContainer(ContainerId) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator
Release container.
releaseContainer(ContainerId) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
releaseContainers(List<Container>) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator
Release containers.
releaseContainers(List<Container>) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
renderMapDataAsTable(List<Map<String, Object>>, List<String>) - Static method in class org.springframework.yarn.support.console.UiUtils
Renders a textual representation of the list of provided Map data
renderParameterInfoDataAsTable(Map<String, String>, boolean, int) - Static method in class org.springframework.yarn.support.console.UiUtils
 
renderParameterInfoDataAsTable(Map<String, String>) - Static method in class org.springframework.yarn.support.console.UiUtils
Renders a textual representation of provided parameter map.
renderTextTable(Table) - Static method in class org.springframework.yarn.support.console.UiUtils
 
renderTextTable(Table, boolean) - Static method in class org.springframework.yarn.support.console.UiUtils
Renders a textual representation of the provided Table
replaceExitCode(String) - Method in class org.springframework.yarn.launch.ExitStatus
Add an exit code to an existing ExitStatus.
reportContainer(Container) - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Notifies monitor of Container.
reportContainer(Container) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 
reportContainerStatus(List<ContainerStatus>) - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Notifies monitor for new ContainerStatus.
reportContainerStatus(ContainerStatus) - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Notifies monitor for new ContainerStatus.
reportContainerStatus(List<ContainerStatus>) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 
reportContainerStatus(ContainerStatus) - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 
resolve(Map<String, Object>) - Method in interface org.springframework.yarn.am.container.ContainerResolver
Resolve resource requests.
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.config.ClientParser
 
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.config.ContainerParser
 
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.config.MasterParser
 
ResourceCompat - Class in org.springframework.yarn.support.compat
Compat class for Resource.
ResourceCompat() - Constructor for class org.springframework.yarn.support.compat.ResourceCompat
 
ResourceLocalizer - Interface in org.springframework.yarn.fs
Interface for resource localizer implementation.
reverse() - Method in class org.springframework.yarn.listener.OrderedComposite
Public getter for the list of items in reverse.
RM_ADDRESS - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for resource manager address.
RpcMessage<T> - Interface in org.springframework.yarn.am
The central interface that any RpcMessage type must implement.
run() - Method in class org.springframework.yarn.container.AbstractYarnContainer
 
run() - Method in interface org.springframework.yarn.container.YarnContainer
This method is called when something is ran in a container.
runInternal() - Method in class org.springframework.yarn.container.AbstractYarnContainer
Internal method to handle the actual AbstractYarnContainer.run() method.
runningCount() - Method in interface org.springframework.yarn.am.monitor.ContainerMonitor
Gets a count of running containers.
runningCount() - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
 

S

SCHEDULER_ADDRESS - Static variable in class org.springframework.yarn.YarnSystemConstants
Default env variable for resource manager scheduler address.
set(List<ContainerLauncherInterceptor>) - Method in class org.springframework.yarn.am.container.AbstractLauncher.ContainerLauncherInterceptorList
Sets the interceptors, clears any existing interceptors.
setAllocator(ContainerAllocator) - Method in class org.springframework.yarn.am.AbstractServicesAppmaster
Sets the ContainerAllocator used for this class.
setApplicationAttemptId(ApplicationAttemptId) - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Sets the application attempt id.
setApplicationDirName(String) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the application dir name.
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher
 
setAppName(String) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the name for submitted application.
setAppName(String) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the name for submitted application.
setArguments(Properties) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
Sets the arguments.
setAutoStartup(boolean) - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Sets the auto startup.
setBeanClassLoader(ClassLoader) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
 
setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
setBeanName(String) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
Sets the bean name.
setClasspath(String) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
Sets incoming classpath.
setClientRmOperations(ClientRmOperations) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the ClientRmOperations implementation for accessing resource manager.
setCommand(String) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
Sets the main command.
setCommands(List<String>) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the commands.
setCommands(String[]) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the commands.
setCommands(List<String>) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the commands starting appmaster.
setCommands(List<String>) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the commands starting appmaster.
setCommands(String[]) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the commands starting appmaster.
setConfiguration(Configuration) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the Yarn configuration.
setConfiguration(Configuration) - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Sets the Yarn configuration.
setConfiguration(Configuration) - Method in class org.springframework.yarn.am.container.AbstractLauncher
Sets the Yarn configuration.
setConfiguration(Configuration) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the Yarn configuration.
setConfiguration(Configuration) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the Yarn configuration.
setConfiguration(YarnConfiguration) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Sets the parent configuration.
setConfiguration(Configuration) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
Sets Yarn configuration for this factory.
setContainerAssign(ContainerAssign<Object>) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the container assign.
setContainerClass(Class<? extends YarnContainer>) - Method in class org.springframework.yarn.container.YarnContainerFactoryBean
Sets the container class.
setContainerRef(YarnContainer) - Method in class org.springframework.yarn.container.YarnContainerFactoryBean
Sets the container ref.
setContextFile(String) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
Sets the context file.
setCopyEntries(Collection<LocalResourcesFactoryBean.CopyEntry>) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
Sets copy entries reference for this factory.
setData(Map<Integer, String>) - Method in class org.springframework.yarn.support.console.TableRow
 
setDefaultYarnAppClasspath(boolean) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
If set to true a default 'yarn' entries will be added to a 'CLASSPATH' environment variable.
setDelimiter(String) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
Sets the delimiter used in a classpath.
setEnvironment(Map<String, String>) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the environment variables.
setEnvironment(Map<String, String>) - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Sets the environment.
setEnvironment(Map<String, String>) - Method in class org.springframework.yarn.am.container.AbstractLauncher
Sets the environment.
setEnvironment(Map<String, String>) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the environment for appmaster.
setEnvironment(Map<String, String>) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the environment for appmaster.
setEnvironment(Map<String, String>) - Method in class org.springframework.yarn.container.AbstractYarnContainer
 
setEnvironment(Map<String, String>) - Method in interface org.springframework.yarn.container.YarnContainer
Sets the environment variables.
setFinalApplicationStatus(FinalApplicationStatus) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the final application status.
setFsUri(String) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Sets the File System ('fs.defaultFS') URI.
setHdfsEntries(Collection<LocalResourcesFactoryBean.TransferEntry>) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
Sets hdfs entries reference for this factory.
setHosts(String[]) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Sets the hosts.
setIncludeBaseDirectory(boolean) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
If set to true a base directory entry will be added to a 'CLASSPATH' environment variable.
setIncludeSystemEnv(boolean) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
If set to true properties from a System.getenv() will be included to environment settings.
setInitialize(boolean) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Indicates whether the configuration object should be initialized (true) or not.
setInterceptors(List<ContainerLauncherInterceptor>) - Method in class org.springframework.yarn.am.container.AbstractLauncher
Set the list of channel interceptors.
setItems(List<? extends S>) - Method in class org.springframework.yarn.listener.OrderedComposite
Public setter for the listeners.
setLauncher(ContainerLauncher) - Method in class org.springframework.yarn.am.AbstractServicesAppmaster
Sets the ContainerLauncher used for this class.
setListeners(List<? extends T>) - Method in class org.springframework.yarn.listener.AbstractCompositeListener
Sets the list of listeners.
setLocal(String) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
Sets default local hdfs base address for entry.
setMapping(Map<String, Integer>) - Method in class org.springframework.yarn.launch.SimpleJvmExitCodeMapper
Supply the ExitCodeMappings
setMaxWidth(int) - Method in class org.springframework.yarn.support.console.TableHeader
Defaults to -1 indicating to ignore the property.
setMemory(int) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Sets the memory for container request defining memory of the resource.
setMemory(int) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the memory.
setMemory(int) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the memory.
setMonitor(ContainerMonitor) - Method in class org.springframework.yarn.am.AbstractServicesAppmaster
Sets the ContainerMonitor used for this class.
setName(String) - Method in class org.springframework.yarn.support.console.TableHeader
 
setParameters(Properties) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the parameters.
setParameters(Properties) - Method in interface org.springframework.yarn.am.YarnAppmaster
Sets parameters for the application.
setParameters(Properties) - Method in class org.springframework.yarn.container.AbstractYarnContainer
 
setParameters(Properties) - Method in interface org.springframework.yarn.container.YarnContainer
Sets the parameters.
setPhase(int) - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Sets the phase.
setPriority(int) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Sets the priority for container request.
setPriority(int) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the priority.
setPriority(int) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the priority.
setProgress(float) - Method in interface org.springframework.yarn.am.allocate.ContainerAllocator
Sets the current progress of application.
setProgress(float) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
 
setProperties(Properties) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Sets the configuration properties.
setProperties(Properties) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean
Sets the configuration properties.
setQueue(String) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the queue.
setQueue(String) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the queue.
setRacks(String[]) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Sets the racks.
setReferenceIfAttributeDefined(BeanDefinitionBuilder, Element, String, String, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property reference to a bean.
setReferenceIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property reference to a bean.
setReferenceIfAttributeDefined(BeanDefinitionBuilder, Element, String, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property reference to a bean.
setRegisterUrlHandler(boolean) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Indicates whether the configuration should register an URL handler (for allowing urls to understand HDFS prefixes, such as hdfs) or not.
setRemote(String) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
Sets default remote hdfs base address for entry.
setResourceLocalizer(ResourceLocalizer) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the resource localizer.
setResourceLocalizer(ResourceLocalizer) - Method in class org.springframework.yarn.am.container.AbstractLauncher
Sets the resource localizer.
setResourceLocalizer(ResourceLocalizer) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the resource localizer for appmaster container.
setResourceLocalizer(ResourceLocalizer) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the resource localizer for appmaster container.
setResources(Set<Resource>) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Sets the configuration resources.
setRmAddress(String) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Sets the Yarn ('yarn.resourcemanager.address') address.
setRmTemplate(AppmasterRmOperations) - Method in class org.springframework.yarn.am.allocate.AbstractAllocator
Sets the rm template.
setRows(List<TableRow>) - Method in class org.springframework.yarn.support.console.Table
 
setRunner(Class<? extends AbstractCommandLineRunner<?>>) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
Sets the runner class.
setSchedulerAddress(String) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean
Sets the Yarn ('yarn.resourcemanager.scheduler.address') address.
setStagingDirectory(Path) - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
 
setStagingDirectory(Path) - Method in interface org.springframework.yarn.fs.ResourceLocalizer
Sets the staging directory.
setStagingDirPath(String) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the staging dir path.
setStagingId(String) - Method in class org.springframework.yarn.fs.DefaultResourceLocalizer
 
setStagingId(String) - Method in interface org.springframework.yarn.fs.ResourceLocalizer
Sets the staging id.
setStderr(String) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
Sets the stderr.
setStdout(String) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean
Sets the stdout.
setTaskExecutor(TaskExecutor) - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Sets the used TaskExecutor.
setTaskScheduler(TaskScheduler) - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Sets the used TaskScheduler.
setTemplate(AppmasterRmOperations) - Method in class org.springframework.yarn.am.AbstractAppmaster
Sets the AppmasterRmOperations template.
setTemplate(ClientRmOperations) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
 
setTrigger(Trigger) - Method in class org.springframework.yarn.am.allocate.AbstractPollingAllocator
Sets Trigger used to trigger polling tasks.
setType(LocalResourceType) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
Sets default LocalResourceType for entry.
setUrl(String) - Method in class org.springframework.yarn.am.track.UrlAppmasterTrackService
Sets the url.
setUsername(String) - Method in class org.springframework.yarn.am.container.AbstractLauncher
Sets the username for the launch context.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property value corresponding to the attribute whose name is provided if that attribute is defined in the given element.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, String, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property value corresponding to the attribute whose name is provided if that attribute is defined in the given element.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property value corresponding to the attribute whose name is provided if that attribute is defined in the given element.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, String, boolean) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property value corresponding to the attribute whose name is provided if that attribute is defined in the given element.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, String, boolean, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property value corresponding to the attribute whose name is provided if that attribute is defined in the given element.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, boolean) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property value corresponding to the attribute whose name is provided if that attribute is defined in the given element.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, boolean, String) - Static method in class org.springframework.yarn.config.YarnNamespaceUtils
Configures the provided bean definition builder with a property value corresponding to the attribute whose name is provided if that attribute is defined in the given element.
setVirtualcores(int) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator
Sets the virtualcores for container request defining number of virtual cpu cores of the resource.
setVirtualcores(int) - Method in class org.springframework.yarn.client.AbstractYarnClient
Sets the virtualcores.
setVirtualcores(int) - Method in class org.springframework.yarn.client.YarnClientFactoryBean
Sets the virtualcores.
setVirtualCores(Resource, int) - Static method in class org.springframework.yarn.support.compat.ResourceCompat
Invokes Resource.setVirtualCores(int).
setVisibility(LocalResourceVisibility) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean
Sets default LocalResourceVisibility for entry.
setWidth(int) - Method in class org.springframework.yarn.support.console.TableHeader
 
setYarnEventPublisher(YarnEventPublisher) - Method in class org.springframework.yarn.support.LifecycleObjectSupport
Sets the yarn event publisher.
SimpleJvmExitCodeMapper - Class in org.springframework.yarn.launch
An implementation of ExitCodeMapper that can be configured through a map from batch exit codes (String) to integer results.
SimpleJvmExitCodeMapper() - Constructor for class org.springframework.yarn.launch.SimpleJvmExitCodeMapper
 
start(String, String, String, String[], Set<String>) - Method in class org.springframework.yarn.launch.AbstractCommandLineRunner
Builds the Application Context(s) and handles 'execution' of a bean.
start() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
startContainers(StartContainersRequest) - Method in interface org.springframework.yarn.am.AppmasterCmOperations
Start container.
startContainers(StartContainersRequest) - Method in class org.springframework.yarn.am.AppmasterCmTemplate
 
state(AppmasterStateListener.AppmasterState) - Method in interface org.springframework.yarn.listener.AppmasterStateListener
Invoked when appmaster state is changing.
state(AppmasterStateListener.AppmasterState) - Method in class org.springframework.yarn.listener.CompositeAppmasterStateListener
 
state(ContainerMonitorListener.ContainerMonitorState) - Method in class org.springframework.yarn.listener.CompositeContainerMonitorStateListener
 
state(ContainerStateListener.ContainerState) - Method in class org.springframework.yarn.listener.CompositeContainerStateListener
 
state(ContainerMonitorListener.ContainerMonitorState) - Method in interface org.springframework.yarn.listener.ContainerMonitorListener
Invoked when monitoring state is changed.
state(ContainerStateListener.ContainerState) - Method in interface org.springframework.yarn.listener.ContainerStateListener
Invoked when container state is changing.
StaticAppmaster - Class in org.springframework.yarn.am
A simple application master implementation which will allocate and launch a number of containers, monitor container statuses and finally exit the application by sending corresponding message back to resource manager.
StaticAppmaster() - Constructor for class org.springframework.yarn.am.StaticAppmaster
 
StaticEventingAppmaster - Class in org.springframework.yarn.am
A simple application master implementation which will allocate and launch a number of containers, monitor container statuses and finally exit the application by sending corresponding message back to resource manager.
StaticEventingAppmaster() - Constructor for class org.springframework.yarn.am.StaticEventingAppmaster
 
stop() - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
stop(Runnable) - Method in class org.springframework.yarn.support.LifecycleObjectSupport
 
stopContainers() - Method in interface org.springframework.yarn.am.AppmasterCmOperations
Stop container.
stopContainers() - Method in class org.springframework.yarn.am.AppmasterCmTemplate
 
STOPPED - Static variable in class org.springframework.yarn.launch.ExitStatus
Convenient constant value representing finished processing with interrupted status.
submitApplication() - Method in class org.springframework.yarn.am.StaticAppmaster
 
submitApplication() - Method in class org.springframework.yarn.am.StaticEventingAppmaster
 
submitApplication() - Method in interface org.springframework.yarn.am.YarnAppmaster
Submit and run application.
submitApplication() - Method in class org.springframework.yarn.client.AbstractYarnClient
 
submitApplication(ApplicationSubmissionContext) - Method in interface org.springframework.yarn.client.ClientRmOperations
Submits a new application into resource manager.
submitApplication(ApplicationSubmissionContext) - Method in class org.springframework.yarn.client.ClientRmTemplate
 
submitApplication() - Method in interface org.springframework.yarn.client.YarnClient
Submits the application known to YarnClient instance.
SYARN_CONTAINER_ID - Static variable in class org.springframework.yarn.YarnSystemConstants
Env variable for container id.
SystemExiter - Interface in org.springframework.yarn.launch
Interface for exiting the JVM.

T

Table - Class in org.springframework.yarn.support.console
Provide a basic concept of a table structure containing a map of column headers and a collection of rows.
Table() - Constructor for class org.springframework.yarn.support.console.Table
 
TableHeader - Class in org.springframework.yarn.support.console
Defines table column headers used by Table.
TableHeader(String, int) - Constructor for class org.springframework.yarn.support.console.TableHeader
Constructor that initializes the table header with the provided header name and the with of the table header.
TableHeader(String) - Constructor for class org.springframework.yarn.support.console.TableHeader
Constructor that initializes the table header with the provided header name.
TableRow - Class in org.springframework.yarn.support.console
Holds the table rows used by Table.
TableRow() - Constructor for class org.springframework.yarn.support.console.TableRow
 
TASK_EXECUTOR_BEAN_NAME - Static variable in class org.springframework.yarn.support.YarnContextUtils
Default task executor bean name
TASK_SCHEDULER_BEAN_NAME - Static variable in class org.springframework.yarn.support.YarnContextUtils
Default task scheduler bean name
toDebugString() - Method in class org.springframework.yarn.am.monitor.DefaultContainerMonitor
Gets this class description as a debug string.
toString() - Method in class org.springframework.yarn.am.allocate.ContainerAllocateData
 
toString() - Method in class org.springframework.yarn.am.allocate.DefaultAllocateCountTracker
 
toString() - Method in class org.springframework.yarn.am.container.ContainerRequestHint
 
toString() - Method in class org.springframework.yarn.event.ContainerAllocationEvent
 
toString() - Method in class org.springframework.yarn.event.ContainerCompletedEvent
 
toString() - Method in class org.springframework.yarn.event.ContainerLaunchedEvent
 
toString() - Method in class org.springframework.yarn.launch.ExitStatus
 
toString() - Method in class org.springframework.yarn.listener.ContainerMonitorListener.ContainerMonitorState
 
toString() - Method in class org.springframework.yarn.support.console.Table
 

U

UiUtils - Class in org.springframework.yarn.support.console
Contains utility methods for rendering data to a formatted console output.
UiUtils() - Constructor for class org.springframework.yarn.support.console.UiUtils
 
UNKNOWN - Static variable in class org.springframework.yarn.launch.ExitStatus
Convenient constant value representing unknown state - assumed not continuable.
updateWidth(int) - Method in class org.springframework.yarn.support.console.TableHeader
Updated the width for this particular column, but only if the value of the passed-in width is higher than the value of the pre-existing width.
UrlAppmasterTrackService - Class in org.springframework.yarn.am.track
Generic AppmasterTrackService implementation whose only purpose is to expose the given url.
UrlAppmasterTrackService(String) - Constructor for class org.springframework.yarn.am.track.UrlAppmasterTrackService
Instantiate with a given url.

V

valueOf(String) - Static method in enum org.springframework.yarn.listener.AppmasterStateListener.AppmasterState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.yarn.listener.ContainerStateListener.ContainerState
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.yarn.listener.AppmasterStateListener.AppmasterState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.yarn.listener.ContainerStateListener.ContainerState
Returns an array containing the constants of this enum type, in the order they are declared.

Y

YarnAppmaster - Interface in org.springframework.yarn.am
Interface defining main application master methods needed for external launch implementations.
YarnClient - Interface in org.springframework.yarn.client
Interface for Spring Yarn facing client methods.
YarnClientFactoryBean - Class in org.springframework.yarn.client
Factory bean building YarnClient instances.
YarnClientFactoryBean() - Constructor for class org.springframework.yarn.client.YarnClientFactoryBean
 
YarnContainer - Interface in org.springframework.yarn.container
A simple interface for container implementations which should work together with rest of the framework when something in a container should be executed.
YarnContainerFactoryBean - Class in org.springframework.yarn.container
Simple factory bean for YarnContainers.
YarnContainerFactoryBean() - Constructor for class org.springframework.yarn.container.YarnContainerFactoryBean
 
YarnContextUtils - Class in org.springframework.yarn.support
Utility methods for accessing common components from the BeanFactory.
YarnContextUtils() - Constructor for class org.springframework.yarn.support.YarnContextUtils
 
YarnEventPublisher - Interface in org.springframework.yarn.event
Interface for publishing Yarn based application events.
YarnNamespaceHandler - Class in org.springframework.yarn.config
Handler for 'yarn' namespace.
YarnNamespaceHandler() - Constructor for class org.springframework.yarn.config.YarnNamespaceHandler
 
YarnNamespaceUtils - Class in org.springframework.yarn.config
Shared utility methods for yarn namespace parsers.
YarnNamespaceUtils() - Constructor for class org.springframework.yarn.config.YarnNamespaceUtils
 
YarnRpcAccessor<P> - Class in org.springframework.yarn.rpc
Base implementation for accessing yarn components over protocol buffer rpc system.
YarnRpcAccessor(Class<P>, Configuration) - Constructor for class org.springframework.yarn.rpc.YarnRpcAccessor
Instantiates a new yarn rpc accessor with a protocol class and Yarn configuration.
YarnRpcCallback<T,P> - Interface in org.springframework.yarn.rpc
Simple helper interface to execute methods via callbacks.
YarnSystemConstants - Class in org.springframework.yarn
Various contants throughout the Spring Yarn libraries.
YarnSystemConstants() - Constructor for class org.springframework.yarn.YarnSystemConstants
 
YarnSystemException - Exception in org.springframework.yarn
General exception indicating a problem in components interacting with yarn.
YarnSystemException(YarnException) - Constructor for exception org.springframework.yarn.YarnSystemException
Constructs YarnSystemException from YarnException.
YarnSystemException(YarnRuntimeException) - Constructor for exception org.springframework.yarn.YarnSystemException
Constructs YarnSystemException from YarnRuntimeException.
YarnSystemException(IOException) - Constructor for exception org.springframework.yarn.YarnSystemException
Constructs YarnSystemException from RemoteException.
YarnSystemException(String, Exception) - Constructor for exception org.springframework.yarn.YarnSystemException
Constructs a general YarnSystemException.
YarnUtils - Class in org.springframework.yarn.support
Different utilities.
YarnUtils() - Constructor for class org.springframework.yarn.support.YarnUtils
 

A C D E F G H I J K L M N O P Q R S T U V Y