A C D E F G H I J L M O P R S T V

A

addProperties(Configuration, Properties) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
Adds the specified properties to the given Configuration object.
afterPropertiesSet() - Method in class org.springframework.data.hadoop.batch.HdfsItemReader
After properties set.
afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveTasklet
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobTasklet
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigTasklet
 
append(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
append(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
append(Path, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
append(String, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
append(Path, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
append(String, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
asProperties(Configuration) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
Returns a static Properties copy of the given configuration.

C

CascadeFactoryBean - Class in org.springframework.data.hadoop.cascading
Factory for declarative Cascade creation.
CascadeFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
CascadeRunner - Class in org.springframework.data.hadoop.cascading
Simple runner for executing Cascades or Flows.
CascadeRunner() - Constructor for class org.springframework.data.hadoop.cascading.CascadeRunner
 
CascadeTasklet - Class in org.springframework.data.hadoop.cascading
Batch tasklet for executing a Cascade or a Flow as part of a job.
CascadeTasklet() - Constructor for class org.springframework.data.hadoop.cascading.CascadeTasklet
 
cat(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
cat(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chgrp(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chgrp(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chgrp(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chgrp(boolean, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chgrpr(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chgrpr(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(boolean, Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(boolean, Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmod(boolean, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmodr(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmodr(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmodr(Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chmodr(Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chown(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chown(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chown(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chown(boolean, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chownr(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
chownr(String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
close() - Method in class org.springframework.data.hadoop.fs.FsShell
 
close() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
close() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
completeLocalOutput(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
completeLocalOutput(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
ConfigurationFactoryBean - Class in org.springframework.data.hadoop.configuration
FactoryBean for creating Configuration instances.
ConfigurationFactoryBean() - Constructor for class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
ConfigurationUtils - Class in org.springframework.data.hadoop.configuration
Reusable utility class for common Configuration operations.
ConfigurationUtils() - Constructor for class org.springframework.data.hadoop.configuration.ConfigurationUtils
 
copy(EnumSet<DistCp.Preserve>, Boolean, Boolean, Boolean, Boolean, String...) - Method in class org.springframework.data.hadoop.fs.DistCp
Copy operation.
copy(EnumSet<DistCp.Preserve>, Boolean, Boolean, String, Integer, Boolean, Boolean, Boolean, Long, Long, String, String...) - Method in class org.springframework.data.hadoop.fs.DistCp
Copies the given resources using the given parameters.
copy(Boolean, Boolean, Boolean, Boolean, Boolean, Boolean, Boolean, String, Integer, Boolean, Boolean, Boolean, Long, Long, String, String...) - Method in class org.springframework.data.hadoop.fs.DistCp
Copies the given resources using the given parameters.
copy(String, String) - Method in class org.springframework.data.hadoop.fs.DistCp
Basic copy operation, between a source and a destination using the defaults.
copy(String, String, String) - Method in class org.springframework.data.hadoop.fs.DistCp
Basic copy operation, between a source and a destination using the defaults.
copy(String...) - Method in class org.springframework.data.hadoop.fs.DistCp
DistCopy using a command-line style (arguments are specified as Strings).
copyFromLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
copyFromLocal(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
copyFromLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyFromLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyFromLocalFile(boolean, Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyFromLocalFile(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyFromLocalFile(boolean, boolean, Path[], Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyFromLocalFile(boolean, boolean, String[], String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyFromLocalFile(boolean, boolean, Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyFromLocalFile(boolean, boolean, String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyToLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
copyToLocal(boolean, boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
copyToLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyToLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyToLocalFile(boolean, Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
copyToLocalFile(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
count(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
count(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
count(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
count(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
cp(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
cp(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
create(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, short, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, short, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, boolean, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, boolean, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, boolean, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, boolean, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, boolean, int, short, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, boolean, int, short, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
create(String, FsPermission, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
createConfiguration(Configuration) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
Creates a configuration instance potentially using the existing one (passed as an argument - which can be null).
createFrom(Configuration, Properties) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
Creates a new Configuration based on the given arguments.
createNewFile(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
createNewFile(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
createPigInstance() - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
 

D

delete(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
delete(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
delete(Path, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
delete(String, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
deleteOnExit(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
deleteOnExit(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
destroy() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner
 
destroy() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
 
destroy() - Method in class org.springframework.data.hadoop.fs.FsShell
 
destroy() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
destroy() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
destroy() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
destroy() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
destroy() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
 
determineRootDir(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
DistCp - Class in org.springframework.data.hadoop.fs
Exposes the Hadoop command-line distcp as an embeddable API.
DistCp(Configuration) - Constructor for class org.springframework.data.hadoop.fs.DistCp
Constructs a new DistCp instance.
DistCp.Preserve - Enum in org.springframework.data.hadoop.fs
Enumeration for the possible attributes that can be preserved by a copy operation.
DistributedCacheFactoryBean - Class in org.springframework.data.hadoop.fs
Factory for easy declarative configuration of a DistributedCache.
DistributedCacheFactoryBean() - Constructor for class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
 
DistributedCacheFactoryBean.CacheEntry - Class in org.springframework.data.hadoop.fs
Class describing an entry of the distributed cache.
DistributedCacheFactoryBean.CacheEntry(DistributedCacheFactoryBean.CacheEntry.EntryType, String) - Constructor for class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry
Constructs a new CacheEntry instance.
DistributedCacheFactoryBean.CacheEntry.EntryType - Enum in org.springframework.data.hadoop.fs
A distributed cache entry type.
du(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
du(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
du(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
du(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
dus(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
dus(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 

E

equals(Object) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
evaluate(ScriptSource) - Method in interface org.springframework.data.hadoop.scripting.ScriptEvaluator
 
evaluate(ScriptSource, Map<String, Object>) - Method in interface org.springframework.data.hadoop.scripting.ScriptEvaluator
 
EvaluationPolicy - Enum in org.springframework.data.hadoop.scripting
The policy for evaluating a script.
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.cascading.CascadeTasklet
 
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.hive.HiveTasklet
 
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.mapreduce.JobTasklet
 
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet
 
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.pig.PigTasklet
 
exists(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
exists(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
expunge() - Method in class org.springframework.data.hadoop.fs.FsShell
 

F

FileSystemFactoryBean - Class in org.springframework.data.hadoop.fs
FactoryBean for creating Hadoop FileSystem instances.
FileSystemFactoryBean() - Constructor for class org.springframework.data.hadoop.fs.FileSystemFactoryBean
 
findPathMatchingResources(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
FsShell - Class in org.springframework.data.hadoop.fs
HDFS FileSystem Shell supporting the 'hadoop fs/dfs [x]' commands as methods.
FsShell(Configuration) - Constructor for class org.springframework.data.hadoop.fs.FsShell
Constructs a new FsShell instance.
FsShell(Configuration, FileSystem) - Constructor for class org.springframework.data.hadoop.fs.FsShell
Constructs a new FsShell instance.

G

get(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
get(boolean, boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
getArguments() - Method in class org.springframework.data.hadoop.pig.PigScript
Returns the arguments associated with this script.
getBlockSize(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getBlockSize(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getCanonicalServiceName() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getClassLoader() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
getConf() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getContentSummary(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getContentSummary(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getDefaultBlockSize() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getDefaultReplication() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getDelegationToken(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getFileBlockLocations(FileStatus, long, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getFileChecksum(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getFileChecksum(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getFileStatus(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getFileStatus(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getFileSystem() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
Returns the Hadoop file system used by this resource loader.
getHomeDirectory() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getHost() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Returns the host.
getLength(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getLength(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getmerge(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
getmerge(String, String, boolean) - Method in class org.springframework.data.hadoop.fs.FsShell
 
getName() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getObject() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner
 
getObject() - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
 
getObject() - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
 
getObject() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
getObject() - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner
 
getObjectType() - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
 
getObjectType() - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
 
getObjectType() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
 
getOrder() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
getPhase() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
getPhase() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
getPort() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Returns the port.
getReplication(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getReplication(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getResource(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
getResource() - Method in class org.springframework.data.hadoop.pig.PigScript
Returns the script resource.
getResources(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
getTimeout() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Returns the timeout.
getUri() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getUsed() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getWorkingDirectory() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
globStatus(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
globStatus(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
globStatus(Path, PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
globStatus(String, PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 

H

HadoopException - Exception in org.springframework.data.hadoop
Core Hadoop Exception.
HadoopException(String, Throwable) - Constructor for exception org.springframework.data.hadoop.HadoopException
Constructs a new HadoopException instance.
HadoopException(String) - Constructor for exception org.springframework.data.hadoop.HadoopException
Constructs a new HadoopException instance.
HadoopFlowFactoryBean - Class in org.springframework.data.hadoop.cascading
Factory for declarative HadoopFlow creation.
HadoopFlowFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 
HadoopSecurityException - Exception in org.springframework.data.hadoop
Security-related exception generated by Hadoop.
HadoopSecurityException(String, Throwable) - Constructor for exception org.springframework.data.hadoop.HadoopSecurityException
Constructs a new HadoopSecurityException instance.
HadoopSecurityException(String) - Constructor for exception org.springframework.data.hadoop.HadoopSecurityException
Constructs a new HadoopSecurityException instance.
hashCode() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
HbaseConfigurationFactoryBean - Class in org.springframework.data.hadoop.hbase
Factory for creating HBase specific configuration.
HbaseConfigurationFactoryBean() - Constructor for class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
HdfsItemReader<T> - Class in org.springframework.data.hadoop.batch
Spring Batch ItemReader implementation for Hadoop FileSystem.
HdfsItemReader(Configuration) - Constructor for class org.springframework.data.hadoop.batch.HdfsItemReader
Instantiates a new hdfs item reader.
HdfsItemReader(FileSystem) - Constructor for class org.springframework.data.hadoop.batch.HdfsItemReader
Instantiates a new hdfs item reader.
HdfsItemReader(HdfsResourceLoader) - Constructor for class org.springframework.data.hadoop.batch.HdfsItemReader
Instantiates a new hdfs item reader.
HdfsResourceLoader - Class in org.springframework.data.hadoop.fs
Spring ResourceLoader over Hadoop FileSystem.
HdfsResourceLoader(Configuration) - Constructor for class org.springframework.data.hadoop.fs.HdfsResourceLoader
Constructs a new HdfsResourceLoader instance.
HdfsResourceLoader(Configuration, URI, String) - Constructor for class org.springframework.data.hadoop.fs.HdfsResourceLoader
Constructs a new HdfsResourceLoader instance.
HdfsResourceLoader(Configuration, URI) - Constructor for class org.springframework.data.hadoop.fs.HdfsResourceLoader
Constructs a new HdfsResourceLoader instance.
HdfsResourceLoader(FileSystem) - Constructor for class org.springframework.data.hadoop.fs.HdfsResourceLoader
Constructs a new HdfsResourceLoader instance.
HdfsScriptFactoryBean - Class in org.springframework.data.hadoop.scripting
Hadoop-customized factory that exposes Hadoop specific variables to scripting languages.
HdfsScriptFactoryBean() - Constructor for class org.springframework.data.hadoop.scripting.HdfsScriptFactoryBean
 
HiveClientFactoryBean - Class in org.springframework.data.hadoop.hive
FactoryBean for easy declaration and creation of a HiveClient using ThriftHive.
HiveClientFactoryBean() - Constructor for class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
HiveServerFactoryBean - Class in org.springframework.data.hadoop.hive
FactoryBean for easy declaration and creation of an embeddable Hive server.
HiveServerFactoryBean() - Constructor for class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
HiveTasklet - Class in org.springframework.data.hadoop.hive
Hive tasklet running Hive scripts on demand, against a HiveClient.
HiveTasklet() - Constructor for class org.springframework.data.hadoop.hive.HiveTasklet
 

I

initialize(URI, Configuration) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
isAutoStartup() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
isAutoStartup() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
isDirectory(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
isDirectory(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
isFile(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
isFile(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
isRunning() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
isRunning() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner
 
isSingleton() - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
 
isSingleton() - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
 
isSingleton() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
 

J

JobFactoryBean - Class in org.springframework.data.hadoop.mapreduce
Factory bean for creating a Hadoop Map-Reduce job.
JobFactoryBean() - Constructor for class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
JobRunner - Class in org.springframework.data.hadoop.mapreduce
Simple runner for submitting Hadoop jobs sequentially.
JobRunner() - Constructor for class org.springframework.data.hadoop.mapreduce.JobRunner
 
JobTasklet - Class in org.springframework.data.hadoop.mapreduce
Batch tasklet for executing one Hadoop job.
JobTasklet() - Constructor for class org.springframework.data.hadoop.mapreduce.JobTasklet
 

L

listStatus(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
listStatus(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
listStatus(Path, PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
listStatus(String, PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
listStatus(Path[]) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
listStatus(String[]) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
listStatus(Path[], PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
listStatus(String[], PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
ls(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
ls(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
ls(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
ls(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
lsr(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
lsr(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 

M

makeQualified(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
makeQualified(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
MapReduceFlowFactoryBean - Class in org.springframework.data.hadoop.cascading
Factory for declarative MapReduceFlow creation.
MapReduceFlowFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
 
merge(Configuration, Configuration) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
Creates a new Configuration by merging the given configurations.
mkdir(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
mkdir(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
mkdirs(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
mkdirs(Path, FsPermission) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
mkdirs(String, short) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
moveFromLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
moveFromLocal(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
moveFromLocalFile(Path[], Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
moveFromLocalFile(String[], String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
moveFromLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
moveFromLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
moveToLocal(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
moveToLocal(boolean, String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
moveToLocalFile(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
moveToLocalFile(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
mv(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
mv(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 

O

open(String, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
open(Path, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
open(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
open(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
org.springframework.data.hadoop - package org.springframework.data.hadoop
Package providing integration of Hadoop (and related) technologies with Spring concepts.
org.springframework.data.hadoop.batch - package org.springframework.data.hadoop.batch
Package providing integration with Spring Batch.
org.springframework.data.hadoop.cascading - package org.springframework.data.hadoop.cascading
Support classes for Cascading.
org.springframework.data.hadoop.configuration - package org.springframework.data.hadoop.configuration
Support classes for configuring Hadoop.
org.springframework.data.hadoop.fs - package org.springframework.data.hadoop.fs
Hadoop FileSystem supporting classes.
org.springframework.data.hadoop.hbase - package org.springframework.data.hadoop.hbase
Package providing integration with Apache HBase.
org.springframework.data.hadoop.hive - package org.springframework.data.hadoop.hive
Package providing integration with Apache Hive.
org.springframework.data.hadoop.mapreduce - package org.springframework.data.hadoop.mapreduce
Support classes for Hadoop core Map Reduce functionality such as job (whether vanilla Map-Reduce or streaming).
org.springframework.data.hadoop.pig - package org.springframework.data.hadoop.pig
Package providing integration with Apache Pig.
org.springframework.data.hadoop.scripting - package org.springframework.data.hadoop.scripting
Support classes for scripting Hadoop.

P

PigContextFactoryBean - Class in org.springframework.data.hadoop.pig
Factory for creating a PigContext instance.
PigContextFactoryBean() - Constructor for class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
PigScript - Class in org.springframework.data.hadoop.pig
Holder class for a pig script.
PigScript(Resource) - Constructor for class org.springframework.data.hadoop.pig.PigScript
Constructs a new PigScript instance from the given resource.
PigScript(Resource, Properties) - Constructor for class org.springframework.data.hadoop.pig.PigScript
Constructs a new PigScript instance.
PigServerFactoryBean - Class in org.springframework.data.hadoop.pig
Factory for creating a PigServer instance.
PigServerFactoryBean() - Constructor for class org.springframework.data.hadoop.pig.PigServerFactoryBean
 
PigTasklet - Class in org.springframework.data.hadoop.pig
Pig tasklet.
PigTasklet() - Constructor for class org.springframework.data.hadoop.pig.PigTasklet
 
postProcess(Map<String, Object>) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptFactoryBean
 
postProcessConfiguration(Configuration) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
processJob(Job) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
put(String, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
put(String, String, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 

R

rename(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
rename(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
rm(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rm(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rm(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rm(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rm(boolean, boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rmr(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rmr(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rmr(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
rmr(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 

S

ScriptEvaluator - Interface in org.springframework.data.hadoop.scripting
Script evaluator.
setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptFactoryBean
 
setArchive(String[]) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
Sets the job archives.
setArguments(String[]) - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
Sets the arguments.
setArguments(String[]) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet
Sets the arguments.
setAutoStartup(boolean) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Indicates whether the Hive client should start automatically (default) or not.
setAutoStartup(boolean) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
Indicates whether the Hive client should start automatically (default) or not.
setBeanClassLoader(ClassLoader) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
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
 
setCmdEnv(Properties) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
Sets the environment for the commands to be executed.
setCodec(Class<? extends CompressionCodec>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job codec class.
setCombiner(Class<? extends Reducer>) - 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.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.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.mapreduce.ToolRunner
Sets the configuration.
setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet
Sets the configuration.
setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
Sets the Hadoop configuration to use.
setCreateSymlink(boolean) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
Indicates whether to create symlinks or not.
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.
setEntries(Collection<DistributedCacheFactoryBean.CacheEntry>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
Sets the entries to be added to the distributed cache.
setExecType(ExecType) - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
Sets the execution type.
setExecutor(Executor) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
Sets the executor for starting the server (which is a blocking operation).
setFile(String[]) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
Sets the job files.
setFileSystem(FileSystem) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
Sets the Hadoop file system for this cache.
setFlows(Collection<Flow>) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
Sets the flows.
setGroupingComparator(Class<? extends RawComparator>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job grouping comparator class.
setHiveClient(HiveClient) - Method in class org.springframework.data.hadoop.hive.HiveTasklet
Sets the hive client for this tasklet.
setHost(String) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Sets the server host.
setInitialize(boolean) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
Indicates whether the configuration object should be initialized (true) or not.
setInputFormat(Class<? extends InputFormat>) - 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.
setInputPaths(List<String>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job input paths.
setJar(Resource) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job jar.
setJarByClass(Class<?>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Determines the job jar 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.JobTasklet
Sets the job to execute.
setJobName(String) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the job name.
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.
setJobs(Collection<Job>) - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
Sets the Jobs to run.
setJobTracker(String) - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
Sets the job tracker.
setKey(Class<?>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job key class.
setLastAlias(String) - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
Sets the last alias.
setLibJar(String[]) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
Sets the job jar libraries.
setListeners(Collection<FlowListener>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the 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.
setLocation(String) - Method in class org.springframework.data.hadoop.batch.HdfsItemReader
Sets the location.
setMapKey(Class<?>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job map key class.
setMapper(Class<? extends Mapper>) - 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(Class<?>) - 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.
setMaxThreads(int) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
Sets the maximum number of threads serving this server.
setMinThreads(int) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
Sets the minimum number of threads serving this server.
setName(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job name.
setNumReduceTasks(Integer) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the number of reduce task for this job.
setNumReduceTasks(Integer) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
Sets the job number of reducer tasks.
setOutputFormat(Class<? extends OutputFormat>) - 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
 
setParallelism(Integer) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the parallelism.
setPartitioner(Class<? extends Partitioner>) - 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.
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
 
setPigContext(PigContext) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the PigContext to use.
setPigServer(PigServer) - Method in class org.springframework.data.hadoop.pig.PigTasklet
Sets the pig server instance used by this tasklet.
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.
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.mapreduce.ToolRunner
Sets the properties.
setProperties(Properties) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet
Sets the properties.
setProperties(Properties) - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
Sets the configuration properties.
setReducer(Class<? extends Reducer>) - 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
 
setResources(Set<Resource>) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
Sets the configuration resources.
setRunAtStartup(boolean) - Method in class org.springframework.data.hadoop.cascading.CascadeRunner
Sets the run at startup.
setRunAtStartup(boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
Indicates whether the jobs should be submitted at startup or not.
setRunAtStartup(boolean) - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
Sets the run at startup.
setScripts(Collection<Resource>) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Sets the scripts to execute once the client connects.
setScripts(Collection<Resource>) - Method in class org.springframework.data.hadoop.hive.HiveTasklet
Sets the scripts to be executed by this tasklet.
setScripts(Collection<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the scripts to execute at startup.
setScripts(Collection<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigTasklet
Sets the pig scripts to be executed by this tasklet.
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.
setSkipStrategy(FlowSkipStrategy) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the skip strategy.
setSortComparator(Class<? extends RawComparator>) - 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
 
setSources(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the sources.
setStepStrategy(FlowStepStrategy) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the step strategy.
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.
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.
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.ToolRunner
Sets the tool.
setTool(Tool) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet
Sets the tool.
setToolClass(Class<? extends Tool>) - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
Sets the tool class.
setToolClass(Class<? extends Tool>) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet
Sets the tool class.
setTraps(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the traps.
setUnitOfWork(UnitOfWork<CascadingStats>) - Method in class org.springframework.data.hadoop.cascading.CascadeRunner
Sets the unit of work.
setUnitOfWork(UnitOfWork<CascadingStats>) - Method in class org.springframework.data.hadoop.cascading.CascadeTasklet
Sets the unit of work.
setUri(URI) - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
Sets the URI (if available) for this file system.
setValidateEachStatement(Boolean) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Indicates whether each statement should be validated or not.
setValidatePaths(Boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Indicates whether the job input/output paths should be validated (default) before the job is submitted.
setValue(Class<?>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job value class.
setVerifyChecksum(boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
setWaitForJob(boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobTasklet
Indicates whether the tasklet should return for the job to complete (default) after submission or not.
setWaitForJobs(boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
Indicates whether the runner should wait for the jobs to finish (the default) 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.
start() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
start() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
startLocalOutput(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
startLocalOutput(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
stop(Runnable) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
stop() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
stop() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
stop(Runnable) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
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
 

T

test(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
test(boolean, boolean, boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
text(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
text(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 
ToolRunner - Class in org.springframework.data.hadoop.mapreduce
Wrapper around ToolRunner allowing for an easier configuration and execution of Tool instances inside Spring.
ToolRunner() - Constructor for class org.springframework.data.hadoop.mapreduce.ToolRunner
 
ToolTasklet - Class in org.springframework.data.hadoop.mapreduce
Tasklet for executing Hadoop Tools.
ToolTasklet() - Constructor for class org.springframework.data.hadoop.mapreduce.ToolTasklet
 
toString() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
toString() - Method in class org.springframework.data.hadoop.pig.PigScript
 
touchz(String) - Method in class org.springframework.data.hadoop.fs.FsShell
 
touchz(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
 

V

valueOf(String) - Static method in enum org.springframework.data.hadoop.fs.DistCp.Preserve
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry.EntryType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.data.hadoop.scripting.EvaluationPolicy
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.data.hadoop.fs.DistCp.Preserve
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry.EntryType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.data.hadoop.scripting.EvaluationPolicy
Returns an array containing the constants of this enum type, in the order they are declared.

A C D E F G H I J L M O P R S T V