A B C D E F G H I J K L M N O P Q R S T U V W 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

AbstractBatchAppmaster - Class in org.springframework.yarn.batch.am

Base application master for running batch jobs.

AbstractBatchAppmaster() - Constructor for class org.springframework.yarn.batch.am.AbstractBatchAppmaster

AbstractBatchPartitionHandler - Class in org.springframework.yarn.batch.partition

Base implementation of Spring Batch PartitionHandler handling partitioning for Yarn containers.

AbstractBatchPartitionHandler(AbstractBatchAppmaster) - Constructor for class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler

Instantiates a new batch partition handler.

AbstractBatchYarnContainer - Class in org.springframework.yarn.batch.container

Base implementation of YarnContainer extending AbstractIntegrationYarnContainer adding functionality for Spring Batch.

AbstractBatchYarnContainer() - Constructor for class org.springframework.yarn.batch.container.AbstractBatchYarnContainer

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

AbstractGenericOptionsParser - Class in org.springframework.data.hadoop.config

AbstractGenericOptionsParser() - Constructor for class org.springframework.data.hadoop.config.AbstractGenericOptionsParser

AbstractImprovedSimpleBeanDefinitionParser - Class in org.springframework.data.hadoop.config

Simple extension to AbstractSimpleBeanDefinitionParser that handles properties references (-ref).

AbstractImprovedSimpleBeanDefinitionParser() - Constructor for class org.springframework.data.hadoop.config.AbstractImprovedSimpleBeanDefinitionParser

AbstractIntegrationYarnContainer - Class in org.springframework.yarn.integration.container

Base implementation of YarnContainer extending AbstractYarnContainer to handle IntegrationAppmasterServiceClient.

AbstractIntegrationYarnContainer() - Constructor for class org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer

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

AbstractPropertiesConfiguredBeanDefinitionParser - Class in org.springframework.data.hadoop.config

Base class for parsing bean definitions of type propertiesConfigured.

AbstractPropertiesConfiguredBeanDefinitionParser() - Constructor for class org.springframework.data.hadoop.config.AbstractPropertiesConfiguredBeanDefinitionParser

AbstractRemoteDao - Class in org.springframework.yarn.batch.repository

Base class for all daos handling remote calls through AppmasterScOperations.

AbstractRemoteDao() - Constructor for class org.springframework.yarn.batch.repository.AbstractRemoteDao

Default constructor.

AbstractRemoteDao(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.AbstractRemoteDao

Constructor which sets the AppmasterMindScOperations.

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.

AbstractYarnClusterTests - Class in org.springframework.yarn.test.junit

Abstract base class providing default functionality for running tests using Yarn mini cluster.

AbstractYarnClusterTests() - Constructor for class org.springframework.yarn.test.junit.AbstractYarnClusterTests

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(JobRepositoryRemoteServiceInterceptor) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList

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.data.hadoop.configuration.ConfigurationUtils

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.data.hadoop.configuration.ConfigurationUtils

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.

addInterceptor(JobRepositoryRemoteServiceInterceptor) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService

Add a service interceptor to the end of the list.

addLibs(Configuration, Resource...) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils

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

addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster

Adds the partitioned step execution state listener.

addProperties(Configuration, Properties) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils

Adds the specified properties to the given Configuration object.

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.

addStepExecutions(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao

AddStepExecutionsReq - Class in org.springframework.yarn.batch.repository.bindings

AddStepExecutionsReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.AddStepExecutionsReq

AddStepExecutionsRes - Class in org.springframework.yarn.batch.repository.bindings

Response for adding step executions.

AddStepExecutionsRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.AddStepExecutionsRes

addStepSplits(StepExecution, String, Set<StepExecution>, Map<StepExecution, ContainerRequestHint>) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster

Adds the step splits.

addValue(Integer, String) - Method in class org.springframework.yarn.support.console.TableRow

Add a value to the to the specified column within this row.

afterAction(Object) - Method in interface org.springframework.data.hadoop.mapreduce.JobExecutor.JobListener

afterPropertiesSet() - Method in class org.springframework.data.hadoop.batch.mapreduce.ToolTasklet

afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadingRunner

afterPropertiesSet() - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hbase.HbaseAccessor

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hbase.HbaseInterceptor

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveExecutor

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveRunner

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveTemplate

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JarExecutor

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JarRunner

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner

afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean

afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigExecutor

afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigRunner

afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigTemplate

afterPropertiesSet() - Method in class org.springframework.data.hadoop.scripting.HdfsScriptRunner

afterPropertiesSet() - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService

afterPropertiesSet() - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean

afterPropertiesSet() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean

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.integration.IntegrationAppmasterServiceClientFactoryBean

afterPropertiesSet() - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean

afterPropertiesSet() - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean

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

afterPropertiesSet() - Method in class org.springframework.yarn.test.support.ClusterDelegatingFactoryBean

afterPropertiesSet() - Method in class org.springframework.yarn.test.support.ConfigurationDelegatingFactoryBean

afterPropertiesSet() - Method in class org.springframework.yarn.test.support.YarnClusterFactoryBean

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.

append(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

append(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

append(Path, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

append(String, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

append(Path, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

append(String, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

applicationContext - Variable in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

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

AppmasterCmTemplate(Configuration, Container) - Constructor for class org.springframework.yarn.am.AppmasterCmTemplate

AppmasterConstants - Class in org.springframework.yarn.am

Public constants used for application master.

AppmasterConstants() - Constructor for class org.springframework.yarn.am.AppmasterConstants

AppmasterMindScOperations - Interface in org.springframework.yarn.integration.ip.mind

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

AppmasterRmTemplate(Configuration) - Constructor for class org.springframework.yarn.am.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.data.hadoop.configuration.ConfigurationUtils

Returns a static Properties copy of the given configuration.

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