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

S

saveExecutionContext(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao

saveExecutionContext(StepExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao

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

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

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

Response for saving execution context.

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

saveExecutionContexts(Collection<StepExecution>) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao

saveJobExecution(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao

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

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

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

Response for saving a job execution.

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

saveStepExecution(StepExecution) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao

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

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

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

Response for saving step execution.

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

SaveStepExecutionRes(Long, Integer) - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionRes

saveStepExecutions(Collection<StepExecution>) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao

SCHEDULER_ADDRESS - Static variable in class org.springframework.yarn.YarnSystemConstants

Default env variable for resource manager scheduler address.

ScriptEvaluator - Interface in org.springframework.data.hadoop.scripting

Script evaluator.

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

Namespace parser for hdp:script.

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

ScriptTasklet - Class in org.springframework.data.hadoop.batch.scripting

Scripting tasklet.

ScriptTasklet() - Constructor for class org.springframework.data.hadoop.batch.scripting.ScriptTasklet

SequenceFileWriterHolder<T extends java.io.Closeable> - Class in org.springframework.data.hadoop.store.support

Holder object for SequenceFile writer.

SequenceFileWriterHolder() - Constructor for class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder

Instantiates a new sequence file writer holder.

SequenceFileWriterHolder(T) - Constructor for class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder

Instantiates a new sequence file writer holder.

SequenceFileWriterHolder(T, Path) - Constructor for class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder

Instantiates a new sequence file writer holder.

serialize(MindRpcMessageHolder, OutputStream) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer

set(List<ContainerLauncherInterceptor>) - Method in class org.springframework.yarn.am.container.AbstractLauncher.ContainerLauncherInterceptorList

Sets the interceptors, clears any existing interceptors.

set(List<JobRepositoryRemoteServiceInterceptor>) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList

Sets the interceptors, clears any existing interceptors.

setAddCascadingJars(boolean) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Indicates whether the Cascading library jars should be added to the flow classpath (through the DistributedCache).

setAllocator(ContainerAllocator) - Method in class org.springframework.yarn.am.AbstractServicesAppmaster

Sets the ContainerAllocator used for this class.

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

Set the AnnotationIntrospector for both serialization and deserialization.

setApplicationAttemptId(ApplicationAttemptId) - Method in class org.springframework.yarn.am.allocate.AbstractAllocator

Sets the application attempt id.

setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar

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

setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests

setApplicationContext(ApplicationContext) - Method in class org.springframework.yarn.batch.am.BatchAppmaster

setApplicationContext(ApplicationContext) - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

setApplicationDirName(String) - Method in class org.springframework.yarn.client.AbstractYarnClient

Sets the application dir name.

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.yarn.event.DefaultYarnEventPublisher

setApplicationId(ApplicationId) - Method in class org.springframework.yarn.test.junit.ApplicationInfo

Sets the application id.

setAppmasterScOperations(AppmasterMindScOperations) - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao

Sets the AppmasterMindScOperations for this implementation.

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

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.

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

Shortcut for MapperFeature.AUTO_DETECT_FIELDS option.

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

Shortcut for MapperFeature.AUTO_DETECT_SETTERS/ MapperFeature.AUTO_DETECT_GETTERS option.

setAutoFlush(boolean) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate

Sets the auto flush.

setAutoStart(boolean) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean

Set whether cluster should be started automatically by this factory instance.

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

Set whether cluster should be started automatically by this factory instance.

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

Indicates whether the Hive client should start automatically (default) or not.

setAutoStartup(boolean) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

Sets the auto startup.

setAutoStartup(boolean) - Method in class org.springframework.yarn.support.LifecycleObjectSupport

Sets the auto startup.

setBasePackage(String[]) - Method in class org.springframework.yarn.integration.convert.MindHolderToObjectConverter

Sets the base packages.

setBasePath(String) - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory

The base path for the datasets in this repository.

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

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

setBeanClassLoader(ClassLoader) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean

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

setBeanFactory(BeanFactory) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.batch.partition.BeanFactoryStepLocator

setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean

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

setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.support.LifecycleObjectSupport

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

setBeanName(String) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

setBeanName(String) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean

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

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

setBeanName(String) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

setBeanName(String) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean

Sets the bean name.

setCacheEntries(Collection<Resource>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean

Sets the cache entries to be added to the distributed cache.

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

Sets the message channel for service dispatching.

setClasspath(String) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean

Sets incoming classpath.

setClassPathEntries(Collection<Resource>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean

Sets the class-path entries to be added to the distributed cache.

setClientRmOperations(ClientRmOperations) - Method in class org.springframework.yarn.client.AbstractYarnClient

Sets the ClientRmOperations implementation for accessing resource manager.

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

Indicates whether the Hadoop file systems should be closed once this factory is destroyed.

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

Indicates whether all the Hadoop file systems should be closed once this factory is destroyed.

setCluster(HadoopCluster) - Method in class org.springframework.data.hadoop.test.support.ConfigurationDelegatingFactoryBean

Sets the StandaloneHadoopCluster

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

Sets the StandaloneYarnCluster

setClusterId(String) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean

Sets the cluster id.

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

Sets the cluster id.

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

Sets the environment for the commands to be executed.

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

Sets the job codec class.

setCodecInfo(CodecInfo) - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy

setCodecInfo(CodecInfo) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy

setCodecInfo(CodecInfo) - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy

Sets the codec info.

setCodecInfo(CodecInfo) - Method in class org.springframework.data.hadoop.store.support.OutputContext

Sets the codec info.

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

Sets the job combiner class.

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

Sets the job combiner.

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.

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

Indicates whether the job output should be compressed or not.

setConf(Configuration) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

setConf(Configuration) - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory

The Hadoop configuraton to be used

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

Sets the configuration.

setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the configuration.

setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean

Sets the configuration.

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

Sets the parent configuration.

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

Sets the Hadoop configuration for the cache.

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

Sets the Hadoop configuration for this file system.

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

Sets the configuration.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests

Sets the Configuration.

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.batch.partition.HdfsSplitBatchPartitionHandler

Sets the Yarn configuration.

setConfiguration(Configuration) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

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.

setConfiguration(Configuration) - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

Sets the Configuration.

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.

setContainerResolver(ContainerResolver) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler

Sets the container resolver.

setContent(byte[]) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder

Sets the content of this holder.

setContent(String) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder

Sets the content of this holder.

setContextFile(String) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean

Sets the context file.

setConversionService(ConversionService) - Method in class org.springframework.yarn.integration.support.IntegrationObjectSupport

Sets the ConversionService.

setCopyEntries(Collection<LocalResourcesFactoryBean.CopyEntry>) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean

Sets copy entries reference for this factory.

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

Indicates whether to create symlinks or not.

setCSVProperty(Element, BeanDefinitionBuilder, String, String) - Static method in class org.springframework.data.hadoop.config.NamespaceUtils

setCSVReferenceProperty(Element, BeanDefinitionBuilder, String, String) - Static method in class org.springframework.data.hadoop.config.NamespaceUtils

setData(Map<Integer, String>) - Method in class org.springframework.yarn.support.console.TableRow

setDatasetRepositoryFactory(DatasetRepositoryFactory) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate

The DatasetRepositoryFactory to use for this template.

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

Define the format for date/time with the given DateFormat.

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.

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

Sets the cascade definition.

setDefinition(FlowDef) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the flow definition.

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

Indicates whether the potential connection created by this config is destroyed at shutdown (default).

setDeleteSinkOnInit(boolean) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean

Sets the delete sink on init.

setDelimiter(String) - Method in class org.springframework.yarn.configuration.EnvironmentFactoryBean

Sets the delimiter used in a classpath.

setDeserializersByType(Map<Class<?>, JsonDeserializer<?>>) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean

Configure custom deserializers for the given types.

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

Sets the encoding.

setEntries(Collection<DistributedCacheFactoryBean.CacheEntry>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean

Sets the entries to be added to the distributed cache.

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.

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

Sets whether to convert any IOException raised to a Spring DataAccessException, compatible with the org.springframework.dao exception hierarchy.

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

Sets the execution type.

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

Sets the ExecutionContextDao for this service class.

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

Sets the executor for starting the server (which is a blocking operation).

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

Sets the TaskExecutor used for executing the Hadoop job.

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

Shortcut for SerializationFeature.FAIL_ON_EMPTY_BEANS option.

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

Specify features to disable.

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

Specify features to enable.

setFileNamingStrategy(FileNamingStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputContext

Sets the file naming strategy.

setFileNamingStrategy(FileNamingStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport

Sets the file naming strategy.

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

Sets the Hadoop file system for this cache.

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

Sets the File System ('fs.default.name') and ('fs.defaultFS') URI for HadoopV1 and HadoopV2 respectively.

setFinalApplicationStatus(FinalApplicationStatus) - Method in class org.springframework.yarn.am.AbstractAppmaster

Sets the final application status.

setFlows(Collection<Flow>) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean

Sets the flows.

setForceSplit(boolean) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

Sets the force split.

setFsUri(String) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean

Sets the File System ('fs.defaultFS') URI.

setGridSize(int) - Method in class org.springframework.yarn.batch.partition.StaticBatchPartitionHandler

Passed to the StepExecutionSplitter in the AbstractBatchPartitionHandler.handle(StepExecutionSplitter, StepExecution) method, instructing it how many StepExecution instances are required, ideally.

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

Sets the job grouping comparator class.

setHadoopCluster(HadoopCluster) - Method in class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests

Sets the HadoopCluster

setHandleNoprefix(boolean) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

Sets the handle noprefix.

setHdfsEntries(Collection<LocalResourcesFactoryBean.TransferEntry>) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean

Sets hdfs entries reference for this factory.

setHeaders(Map<String, String>) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcMessageHolder

Sets the headers of this holder.

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

Sets the hive client for this tasklet.

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

Sets the HiveClient factory.

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

Sets the hive template.

setHost(String) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean

Sets the server host.

setHosts(String[]) - Method in class org.springframework.yarn.am.allocate.DefaultContainerAllocator

Sets the hosts.

setId(String) - Method in class org.springframework.data.hadoop.test.support.ClusterInfo

setId(String) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterDelegatingFactoryBean

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

setId(String) - Method in class org.springframework.yarn.test.support.ClusterInfo

setIdleTimeout(long) - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport

Sets the idle timeout.

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.

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

Shortcut for SerializationFeature.INDENT_OUTPUT option.

setInitialDelay(long) - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger

Specify the delay for the initial execution.

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

Indicates whether the configuration object should be initialized (true) or not.

setInitialize(boolean) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean

Indicates whether the configuration object should be initialized (true) or not.

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

Sets the job input format class.

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

Sets the job input format.

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

Sets the job input path.

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

Sets the job input paths.

setIntegrationServiceClient(IntegrationAppmasterServiceClient<?>) - Method in class org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer

Sets the integration service client.

setInterceptors(List<ContainerLauncherInterceptor>) - Method in class org.springframework.yarn.am.container.AbstractLauncher

Set the list of channel interceptors.

setInterceptors(List<JobRepositoryRemoteServiceInterceptor>) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService

Set the list of channel interceptors.

setInWritingPrefix(String) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport

Sets the in writing prefix.

setInWritingSuffix(String) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport

Sets the in writing suffix.

setItems(List<? extends S>) - Method in class org.springframework.data.hadoop.store.support.OrderedComposite

Public setter for the listeners.

setItems(List<? extends S>) - Method in class org.springframework.yarn.listener.OrderedComposite

Public setter for the listeners.

setJar(Resource) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the job jar (which might not be on the classpath).

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

Sets the job jar (which might not be on the classpath).

setJarByClass(Class<?>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Determines the job jar (available on the classpath) based on the given class.

setJarByClass(Class<?>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean

Determines the job jar (available on the classpath) based on the given class.

setJob(Job) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean

Sets the Hadoop job (as an alternative to setting a configuration).

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

Sets the job to execute.

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

Sets the JobExecutionDao for this service class.

setJobExplorer(JobExplorer) - Method in class org.springframework.yarn.batch.container.AbstractBatchYarnContainer

Sets the job explorer.

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

Sets the JobInstanceDao for this service class.

setJobLauncher(JobLauncher) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster

Sets the job launcher.

setJobName(String) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Sets the job name.

setJobName(String) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster

Sets the job name.

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

Sets the jobs to execute by (bean) name.

setJobParametersConverter(JobParametersConverter) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster

Injection setter for JobParametersConverter.

setJobPoolingInterval(Long) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the job pooling interval.

setJobPriority(String) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Sets the job priority.

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

Sets the job repository remote service.

setJobs(Collection<Job>) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor

Sets the jobs to execute.

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

Sets the job tracker.

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

Sets the Job Tracker ('mapred.jobtracker') URI for HadoopV1.

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

Sets the job key class.

setKeyFileName(String) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

The name of the key for the file name in each ExecutionContext.

setKeySplitLength(String) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

The name of the key for the file split length in each ExecutionContext.

setKeySplitStart(String) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

The name of the key for the file split start in each ExecutionContext.

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

Indicates whether the configured jobs should be 'killed' when the application shuts down (default) or not.

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

Sets the last alias.

setLauncher(ContainerLauncher) - Method in class org.springframework.yarn.am.AbstractServicesAppmaster

Sets the ContainerLauncher used for this class.

setLineDataMapper(LineDataMapper<T>) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader

Sets the line data mapper.

setListeners(Collection<CascadeListener>) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean

Sets the listeners.

setListeners(List<? extends T>) - Method in class org.springframework.yarn.listener.AbstractCompositeListener

Sets the list of listeners.

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

Indicates whether to load the defaults (the default) or not for this configuration.

setLoader(ResourcePatternResolver) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar

Sets the resource pattern loader.

setLocal(String) - Method in class org.springframework.yarn.fs.LocalResourcesFactoryBean

Sets default local hdfs base address for entry.

setLocalEntries(Collection<Resource>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean

Sets the local entries to be added to the distributed cache.

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

Sets the target class by name.

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

Sets the MapJobRepositoryFactoryBean for this service class.

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

Sets the job map key class.

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

Sets the job mapper class.

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

Sets the job mapper.

setMapping(Map<String, Integer>) - Method in class org.springframework.yarn.launch.SimpleJvmExitCodeMapper

Supply the ExitCodeMappings

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

Sets the job map value class.

setMaxConcurrentSteps(Integer) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the max concurrent steps.

setMaxMessageSize(int) - Method in class org.springframework.yarn.integration.ip.mind.MindRpcSerializer

Sets the max message size for transport.

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

Sets the maximum number of threads serving this server.

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.

setMessageChannel(SubscribableChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterService

Sets the message channel where messages are dispatched.

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

Sets the minimum number of threads serving this server.

setMonitor(ContainerMonitor) - Method in class org.springframework.yarn.am.AbstractServicesAppmaster

Sets the ContainerMonitor used for this class.

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

Sets the job name.

setName(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy

Sets the file name part.

setName(String) - Method in class org.springframework.yarn.support.console.TableHeader

setNodes(int) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterDelegatingFactoryBean

setNodes(int) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean

Sets the number of nodes.

setNodes(int) - Method in class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster

Sets a number of nodes for cluster.

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

setNodes(int) - Method in class org.springframework.yarn.test.support.StandaloneYarnCluster

Sets a number of nodes for cluster.

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

Sets the number of nodes.

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

Sets the number of reduce task for this job.

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

Sets the job number of reducer tasks.

setNumDfs(int) - Method in class org.springframework.data.hadoop.test.support.ClusterInfo

setNumDfs(int) - Method in class org.springframework.yarn.test.support.ClusterInfo

setNumYarn(int) - Method in class org.springframework.yarn.test.support.ClusterInfo

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

Set the ObjectMapper instance to use.

setOrder(int) - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy

Sets the order.

setOrder(int) - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy

Sets the order.

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

Sets the job output format class.

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

Sets the job output format.

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

Sets the job output path.

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

Sets the job output paths.

setOverwrite(boolean) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport

Sets the flag indicating if written files may be overwritten.

setOwner(Path, String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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

setParallelism(Integer) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Sets the parallelism.

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.

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

Sets the job partitioner class.

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

Sets the job partitioner.

setPath(Path) - Method in class org.springframework.data.hadoop.store.support.StreamsHolder

Sets the path.

setPathsToSkip(Collection<String>) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Sets the paths to skip.

setPermission(Path, FsPermission) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

setPermission(String, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

setPhase(int) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

Sets the phase.

setPhase(int) - Method in class org.springframework.yarn.support.LifecycleObjectSupport

Sets the phase.

setPigContext(PigContext) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Sets the PigContext to use.

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

Sets the pig server instance used by this class.

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

Sets the PigServer factory.

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

Sets the pig template used by this class.

setPort(int) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean

Sets the server port.

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

Sets the server port.

setPostAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.cascading.CascadingRunner

Actions to be invoked after running the action.

setPostAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.hive.HiveRunner

Actions to be invoked after running the action.

setPostAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.mapreduce.JarRunner

Actions to be invoked after running the action.

setPostAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.mapreduce.JobRunner

Actions to be invoked after running the action.

setPostAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner

Actions to be invoked after running the action.

setPostAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.pig.PigRunner

Actions to be invoked after running the action.

setPreAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.cascading.CascadingRunner

Actions to be invoked before running the action.

setPreAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.hive.HiveRunner

Actions to be invoked before running the action.

setPreAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.mapreduce.JarRunner

Actions to be invoked before running the action.

setPreAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.mapreduce.JobRunner

Actions to be invoked before running the action.

setPreAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner

Actions to be invoked before running the action.

setPreAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.pig.PigRunner

Actions to be invoked before running the action.

setPrefix(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy

Sets the prefix preceding rolling number part.

setPrefix(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy

Sets the prefix preceding name part.

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.data.hadoop.cascading.CascadeFactoryBean

Sets the properties.

setProperties(Properties) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the properties.

setProperties(Properties) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean

Sets the properties.

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

Sets the configuration properties.

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

Sets the configuration properties.

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

Sets the configuration properties.

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

The configuration properties to set for this job.

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

Sets the configuration properties to use.

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

Sets the configuration properties.

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.

setPropertyValue(Element, BeanDefinitionBuilder, String, String) - Static method in class org.springframework.data.hadoop.config.NamespaceUtils

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.

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

Sets the job reducer class.

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

Sets the job reducer.

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

Indicates whether the configuration should register an URL handler (for allowing urls to understand HDFS prefixes, such as hdfs) or not.

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.

setrep(short, String) - Method in class org.springframework.data.hadoop.fs.FsShell

setrep(short, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

setrep(boolean, short, String) - Method in class org.springframework.data.hadoop.fs.FsShell

setrep(boolean, short, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

setrep(long, boolean, short, String) - Method in class org.springframework.data.hadoop.fs.FsShell

setrep(long, boolean, short, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

setReplication(Path, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

setReplication(String, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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

The repository factory that can be used to create daos for the explorer.

setrepr(short, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

setrepr(short, String) - Method in class org.springframework.data.hadoop.fs.FsShell

setrepr(long, short, String) - Method in class org.springframework.data.hadoop.fs.FsShell

setrepr(long, short, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

setRequestChannel(MessageChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClient

Set the request channel for outgoing messages.

setRequestChannel(MessageChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean

Sets the outbount request channel.

setResmsg(String) - Method in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject

setResource(Resource) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader

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

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

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.

setResourcePatternResolver(ResourcePatternResolver) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

Sets the resource pattern resolver.

setResources(Set<Resource>) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean

Sets the configuration resources.

setResources(Resource[]) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

The resources to assign to each partition.

setResources(Set<Resource>) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean

Sets the configuration resources.

setResponseChannel(PollableChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClient

Set the response channel for incoming messages.

setResponseChannel(PollableChannel) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean

Sets the inbound response channel.

setResstate(String) - Method in class org.springframework.yarn.integration.ip.mind.binding.BaseResponseObject

setRmAddress(String) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean

Sets the Yarn ('yarn.resourcemanager.address') address.

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

Sets the Yarn resource manager ('yarn.resource.manager') URI for HadoopV2.

setRmTemplate(AppmasterRmOperations) - Method in class org.springframework.yarn.am.allocate.AbstractAllocator

Sets the rm template.

setRolloverSize(long) - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy

Sets the rollover size.

setRolloverStrategy(RolloverStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputContext

Sets the rollover strategy.

setRolloverStrategy(RolloverStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport

Sets the rollover strategy.

setRows(List<TableRow>) - Method in class org.springframework.yarn.support.console.Table

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

Sets the run at startup.

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

Indicates whether the scripts should run at container startup or not (the default).

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

Indicates whether the jar should run at container startup or not (the default).

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

Indicates whether the jobs should be submitted at startup (default) or not.

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

Indicates whether the tool should run at container startup (the default) or not.

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

Indicates whether the scripts should run at container startup or not (the default).

setRunner(Class<? extends AbstractCommandLineRunner<?>>) - Method in class org.springframework.yarn.launch.LaunchCommandsFactoryBean

Sets the runner class.

setSaveState(boolean) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader

Set the flag that determines whether to save internal data for ExecutionContext.

setSchedulerAddress(String) - Method in class org.springframework.yarn.configuration.ConfigurationFactoryBean

Sets the Yarn ('yarn.resourcemanager.scheduler.address') address.

setScriptCallback(Callable<Object>) - Method in class org.springframework.data.hadoop.batch.scripting.ScriptTasklet

setScripts(Collection<HiveScript>) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean

Sets the scripts to execute once the client connects.

setScripts(Collection<HiveScript>) - Method in class org.springframework.data.hadoop.hive.HiveExecutor

Sets the scripts to be executed by this tasklet.

setScripts(Collection<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigExecutor

Sets the pig scripts to be executed by this class.

setScripts(Collection<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Sets the scripts to execute at startup.

setSerializers(JsonSerializer<?>...) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean

Configure custom serializers.

setSerializersByType(Map<Class<?>, JsonSerializer<?>>) - Method in class org.springframework.yarn.integration.support.Jackson2ObjectMapperFactoryBean

Configure custom serializers for the given types.

setServiceImpl(Class<AppmasterServiceClient>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceClientFactoryBean

Set the class implementing appmaster service client.

setServiceImpl(Class<AppmasterService>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean

Set the class implementing appmaster service.

setServiceRef(IntegrationAppmasterService<?>) - Method in class org.springframework.yarn.integration.IntegrationAppmasterServiceFactoryBean

Sets the appmaster service as an instance.

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

Define the date/time format with a SimpleDateFormat.

setSink(Tap) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

setSinks(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the sinks.

setSocketSupport(PortExposingTcpSocketSupport) - Method in class org.springframework.yarn.integration.IntegrationAppmasterService

Sets the socket support for this service.

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

Sets the socket support to be used to get port info from a server socket.

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

Sets the job sort comparator class.

setSource(Tap) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the source.

setSources(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the sources.

setSplitFile(boolean) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

Sets the flat indicating if file input should be split.

setSplitLength(long) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader

Sets the split length.

setSplitSize(int) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

Sets the input split size relative to block size of the HDFS file.

setSplitStart(long) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader

Sets the split start.

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.

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

Sets the StepExecutionDao for this service class.

setStepLocator(StepLocator) - Method in class org.springframework.yarn.batch.container.AbstractBatchYarnContainer

Sets the step locator.

setStepName(String) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler

Sets the step name.

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

Indicates whether, when/if the associated connection is destroyed, whether the proxy is stopped or not.

setStoreEventPublisher(StoreEventPublisher) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

Sets the store event publisher.

setStrategies(List<? extends FileNamingStrategy>) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy

Sets the list of strategies.

setStrategies(List<? extends RolloverStrategy>) - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy

Sets the list of strategies.

setStream(T) - Method in class org.springframework.data.hadoop.store.support.StreamsHolder

Sets the stream.

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

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

Sets the table factory.

setTableNames(String[]) - Method in class org.springframework.data.hadoop.hbase.HbaseInterceptor

setTail(Pipe) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the tail.

setTails(Collection<Pipe>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the tails.

setTaskExecutor(TaskExecutor) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

Sets the used TaskExecutor.

setTaskExecutor(TaskExecutor) - Method in class org.springframework.yarn.support.LifecycleObjectSupport

Sets the used TaskExecutor.

setTaskScheduler(TaskScheduler) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

Sets the used TaskScheduler.

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

setTimeout(int) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean

Sets the connection timeout.

setTimes(Path, long, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

setTimes(String, long, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

setTool(Tool) - Method in class org.springframework.data.hadoop.mapreduce.ToolExecutor

Sets the tool.

setToolClass(String) - Method in class org.springframework.data.hadoop.mapreduce.ToolExecutor

Sets the tool class by name.

setTraps(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the traps.

setTrigger(Trigger) - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport

Sets the trigger.

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.

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

Sets the URI (if available) for this file system.

setUrl(String) - Method in class org.springframework.yarn.am.track.UrlAppmasterTrackService

Sets the url.

setUseCodecs(boolean) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

Indicates whether to use (or not) the codecs found inside the Hadoop configuration.

setUsePath(boolean) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner

If set to true resource path is set using URL.getPath(), otherwise URL.toExternalForm() is used.

setUser(String) - Method in class org.springframework.data.hadoop.fs.DistCp

Sets the user impersonation (optional) for creating this utility.

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

Sets the user impersonation (optional) for creating this file-system.

setUser(String) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Sets the user impersonation (optional) for executing Pig jobs.

setUsername(String) - Method in class org.springframework.yarn.am.container.AbstractLauncher

Sets the username for the launch context.

setValidateEachStatement(Boolean) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean

Indicates whether each statement should be validated or not.

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

Sets the job value class.

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.

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

Indicates whether the job execution is verbose (the default) or not.

setVerifyChecksum(boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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.

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

Indicates whether the 'runner' should wait for the job to complete (default) after submission or not.

setWidth(int) - Method in class org.springframework.yarn.support.console.TableHeader

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

Sets the job working directory.

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

setWrappedStream(T) - Method in class org.springframework.data.hadoop.store.support.StreamsHolder

Sets the wrapped stream.

setWritePosition(long) - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy

setWritePosition(long) - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy

setWritePosition(long) - Method in interface org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategy

Sets the write position.

setWritePosition(long) - Method in class org.springframework.data.hadoop.store.support.OutputContext

Sets the write position.

setWritePosition(long) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport

Sets the write position.

setYarnApplicationState(YarnApplicationState) - Method in class org.springframework.yarn.test.junit.ApplicationInfo

Sets the yarn application state.

setYarnClient(YarnClient) - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

Sets the YarnClient.

setYarnCluster(YarnCluster) - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

Sets the YarnCluster

setYarnEventPublisher(YarnEventPublisher) - Method in class org.springframework.yarn.support.LifecycleObjectSupport

Sets the yarn event publisher.

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

Sets the HBase Zookeeper port for clients to connect to.

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

Sets the HBase Zookeeper Quorum host(s).

shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.HiveRunnerParser

shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.JarRunnerParser

shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.ScriptParser

shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.ToolRunnerParser

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

SimplerFileSystem - Class in org.springframework.data.hadoop.fs

FileSystem decorator that overloads methods to accept Strings instead of Paths.

SimplerFileSystem(FileSystem) - Constructor for class org.springframework.data.hadoop.fs.SimplerFileSystem

Constructs a new SimplerFileSystem instance.

SizeRolloverStrategy - Class in org.springframework.data.hadoop.store.strategy.rollover

A RolloverStrategy using a size limiting a rollover operation.

SizeRolloverStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy

Instantiates a new size rollover strategy.

SizeRolloverStrategy(long) - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy

Instantiates a new size rollover strategy.

SizeRolloverStrategy(String) - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy

Instantiates a new size rollover strategy.

StandaloneHadoopCluster - Class in org.springframework.data.hadoop.test.support

Standalone simple mini cluster having MR and Hdfs nodes.

StandaloneHadoopCluster(String) - Constructor for class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster

Instantiates a mini cluster with default cluster node count.

StandaloneHadoopCluster(String, int) - Constructor for class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster

Instantiates a mini cluster with given cluster node count.

StandaloneYarnCluster - Class in org.springframework.yarn.test.support

Standalone simple mini cluster having Yarn and Hdfs nodes.

StandaloneYarnCluster(String) - Constructor for class org.springframework.yarn.test.support.StandaloneYarnCluster

Instantiates a mini cluster with default cluster node count.

StandaloneYarnCluster(String, int) - Constructor for class org.springframework.yarn.test.support.StandaloneYarnCluster

Instantiates a mini cluster with given cluster node count.

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

start() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

start() - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport

Starts the poller.

start() - Method in interface org.springframework.data.hadoop.test.context.HadoopCluster

Starts the cluster.

start() - Method in class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster

start - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstancesReq

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

start() - Method in interface org.springframework.yarn.test.context.YarnCluster

Starts the cluster.

start() - Method in class org.springframework.yarn.test.support.StandaloneYarnCluster

startContainers(StartContainersRequest) - Method in interface org.springframework.yarn.am.AppmasterCmOperations

Start container.

startContainers(StartContainersRequest) - Method in class org.springframework.yarn.am.AppmasterCmTemplate

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

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

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

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

startTime - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType

startTime - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType

state(PartitionedStepExecutionStateListener.PartitionedStepExecutionState, StepExecution) - Method in class org.springframework.yarn.batch.listener.CompositePartitionedStepExecutionStateListener

state(PartitionedStepExecutionStateListener.PartitionedStepExecutionState, StepExecution) - Method in interface org.springframework.yarn.batch.listener.PartitionedStepExecutionStateListener

Invoked when partitioned step state is changing.

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

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

Implementation of Spring Batch PartitionHandler which does partitioning based on static grid size.

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

Instantiates a new static batch partition handler.

StaticBatchPartitionHandler(AbstractBatchAppmaster, int) - Constructor for class org.springframework.yarn.batch.partition.StaticBatchPartitionHandler

Instantiates a new static batch partition handler.

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

StaticFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming

A FileNamingStrategy which simply uses a static file name.

StaticFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy

Instantiates a new static file naming strategy.

StaticFileNamingStrategy(String) - Constructor for class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy

Instantiates a new static file naming strategy.

status - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType

status - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType

status - Variable in class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes

status - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextRes

stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetExecutionContextReq

stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetStepExecutionRes

stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.PartitionedStepExecutionStatusReq

stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.SaveExecutionContextReq

stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionReq

stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextReq

stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionReq

stepExecutionId - Variable in class org.springframework.yarn.batch.repository.bindings.GetStepExecutionReq

stepExecutions - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType

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

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

stepName - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType

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

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

stop() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

stop(Runnable) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport

stop() - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport

Stops the poller.

stop() - Method in interface org.springframework.data.hadoop.test.context.HadoopCluster

Stops the cluster.

stop() - Method in class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster

stop() - Method in class org.springframework.yarn.support.LifecycleObjectSupport

stop(Runnable) - Method in class org.springframework.yarn.support.LifecycleObjectSupport

stop() - Method in interface org.springframework.yarn.test.context.YarnCluster

Stops the cluster.

stop() - Method in class org.springframework.yarn.test.support.StandaloneYarnCluster

stopCluster(Object) - Static method in class org.springframework.data.hadoop.test.support.compat.MiniMRClusterCompat

Finds and calls lifecycle stop method for given cluster via reflection.

stopContainers() - Method in interface org.springframework.yarn.am.AppmasterCmOperations

Stop container.

stopContainers() - Method in class org.springframework.yarn.am.AppmasterCmTemplate

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

Stops running job.

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

Stops running job.

STOPPED - Static variable in class org.springframework.yarn.launch.ExitStatus

Convenient constant value representing finished processing with interrupted status.

StoreContextUtils - Class in org.springframework.data.hadoop.store.support

Utility methods for accessing common components from the BeanFactory.

StoreContextUtils() - Constructor for class org.springframework.data.hadoop.store.support.StoreContextUtils

StoreEventPublisher - Interface in org.springframework.data.hadoop.store.event

Interface for publishing store based application events.

StoreException - Exception in org.springframework.data.hadoop.store

An exception that indicates there was an error accessing the the underlying HDFS store implementation.

StoreException(String, Throwable) - Constructor for exception org.springframework.data.hadoop.store.StoreException

Constructor for StoreException.

StoreException(String) - Constructor for exception org.springframework.data.hadoop.store.StoreException

Constructor for StoreException.

StoreObjectSupport - Class in org.springframework.data.hadoop.store.support

Base implementation of a store objects sharing a common functionality among store formats.

StoreObjectSupport(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.support.StoreObjectSupport

Instantiates a new abstract store support.

StoreSystemConstants - Class in org.springframework.data.hadoop.store

Various constants throughout the store package.

StoreSystemConstants() - Constructor for class org.springframework.data.hadoop.store.StoreSystemConstants

StoreUtils - Class in org.springframework.data.hadoop.store.support

Utility methods for store package.

StoreUtils() - Constructor for class org.springframework.data.hadoop.store.support.StoreUtils

StreamJobFactoryBean - Class in org.springframework.data.hadoop.mapreduce

Factory bean focused on creating streaming jobs.

StreamJobFactoryBean() - Constructor for class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean

StreamsHolder<T extends java.io.Closeable> - Class in org.springframework.data.hadoop.store.support

Holder object for streams.

StreamsHolder() - Constructor for class org.springframework.data.hadoop.store.support.StreamsHolder

Instantiates a new streams holder.

StreamsHolder(T, T) - Constructor for class org.springframework.data.hadoop.store.support.StreamsHolder

Instantiates a new streams holder.

StreamsHolder(T, T, Path) - Constructor for class org.springframework.data.hadoop.store.support.StreamsHolder

Instantiates a new streams holder.

stringPropertyNames() - Method in class org.springframework.data.hadoop.config.LinkedProperties

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.batch.am.BatchAppmaster

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.

submitApplication() - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

Submit an application.

submitApplicationAndWait() - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

Submits application and wait state.

submitApplicationAndWait(long, TimeUnit) - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

Submits application and wait state.

submitApplicationAndWaitState(long, TimeUnit, YarnApplicationState...) - Method in class org.springframework.yarn.test.junit.AbstractYarnClusterTests

Submits application and wait state.

SYARN_CONTAINER_ID - Static variable in class org.springframework.yarn.YarnSystemConstants

Env variable for container id.

synchronizeStatus(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao

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

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

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

Response for synching status.

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

SynchronizeStatusRes(Integer, BatchStatus) - Constructor for class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes

SystemExiter - Interface in org.springframework.yarn.launch

Interface for exiting the JVM.