- ScriptEvaluator - Interface in org.springframework.data.hadoop.scripting
-
Script evaluator.
- SecurityAuthMethod - Enum in org.springframework.data.hadoop.security
-
Supported security authentication methods in Spring Yarn.
- setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
-
- setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptRunner
-
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
- setBeanFactory(BeanFactory) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
-
- setBeanName(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
- setBeanName(String) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
-
- setCacheEntries(Collection<Resource>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
-
Sets the cache entries to be added to the distributed cache.
- setClassPathEntries(Collection<Resource>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
-
Sets the class-path entries to be added to the distributed cache.
- 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.
- 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.
- 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.
- 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
-
- 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.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.scripting.HdfsScriptRunner
-
Sets the Hadoop configuration to use.
- setCreateSymlink(boolean) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
-
Indicates whether to create symlinks or not.
- setEntries(Collection<DistributedCacheFactoryBean.CacheEntry>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
-
Sets the entries to be added to the distributed cache.
- setExecutor(Executor) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
-
Sets the TaskExecutor used for executing the Hadoop job.
- 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.defaultFS') URI
- setGroupingComparator(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
Sets the job grouping comparator class.
- setHandleNoprefix(boolean) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Sets the handle noprefix.
- setInitialize(boolean) - Method in class org.springframework.data.hadoop.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.
- 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.mapreduce.JobFactoryBean
-
Determines the job jar (available on the classpath) based on the given class.
- setJob(Job) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
-
Sets the job to execute.
- setJobHistoryUri(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Sets the Job Tracker ('mapreduce.jobhistory.address') URI.
- setJobNames(String...) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
-
Sets the jobs to execute by (bean) name.
- setJobs(Collection<Job>) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
-
Sets the jobs to execute.
- setKey(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
Sets the job key class.
- 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.
- 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.
- 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.
- 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.
- setMapValue(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
Sets the job map value class.
- setName(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
Sets the job name.
- setNamenodePrincipal(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Sets the used namenode principal.
- setNamenodePrincipal(String) - Method in class org.springframework.data.hadoop.security.HadoopSecurity
-
- 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.
- 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.
- 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
-
- 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.
- setPermission(Path, FsPermission) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- setPermission(String, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- 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.
- 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.
- setProperties(Properties) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
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.
- 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.
- 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.
- 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
-
- 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
-
- 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.
- setRmManagerPrincipal(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Sets the used resource manager principal.
- setRmManagerPrincipal(String) - Method in class org.springframework.data.hadoop.security.HadoopSecurity
-
- setRmManagerUri(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Sets the Yarn resource manager ('yarn.resourcemanager.address') URI.
- 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.
- setSecurityAuthMethod(SecurityAuthMethod) - Method in class org.springframework.data.hadoop.security.HadoopSecurity
-
- setSecurityMethod(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Sets the used security method.
- setSortComparator(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
Sets the job sort comparator class.
- 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.
- setUri(URI) - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
-
Sets the URI (if available) for this file system.
- setUseCodecs(boolean) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Indicates whether to use (or not) the codecs found inside the Hadoop
configuration.
- 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.
- setUserKeytab(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Sets a path to a keytab file.
- setUserKeytab(String) - Method in class org.springframework.data.hadoop.security.HadoopSecurity
-
- setUserPrincipal(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
-
Sets the the user login principal.
- setUserPrincipal(String) - Method in class org.springframework.data.hadoop.security.HadoopSecurity
-
- setValue(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
-
Sets the job value class.
- 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
-
- 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.
- 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
-
- 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.
- 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
-
- 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.
- 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
-