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

A

addArchives(Configuration, Resource...) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
 
addFiles(Configuration, Resource...) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
 
addLibs(Configuration, Resource...) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
 
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.cascading.CascadeFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadingRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hbase.HbaseAccessor
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hbase.HbaseInterceptor
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveTemplate
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JarRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigRunner
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigTemplate
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.scripting.HdfsScriptRunner
 
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.

B

bindResource(String, HTableInterface) - Static method in class org.springframework.data.hadoop.hbase.HbaseSynchronizationManager
Binds the given resource for the given key to the current thread.

C

call() - Method in class org.springframework.data.hadoop.cascading.CascadingRunner
 
call() - Method in class org.springframework.data.hadoop.hive.HiveRunner
 
call() - Method in class org.springframework.data.hadoop.mapreduce.JarRunner
 
call() - Method in class org.springframework.data.hadoop.mapreduce.JobRunner
 
call() - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner
 
call() - Method in class org.springframework.data.hadoop.pig.PigRunner
 
CascadeFactoryBean - Class in org.springframework.data.hadoop.cascading
Factory for declarative Cascade creation.
CascadeFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
CascadingRunner - Class in org.springframework.data.hadoop.cascading
Simple runner for executing Cascades or Flows.
CascadingRunner() - Constructor for class org.springframework.data.hadoop.cascading.CascadingRunner
 
CascadingTasklet - Class in org.springframework.data.hadoop.cascading
Batch tasklet for executing a Cascade as part of a job.
CascadingTasklet() - Constructor for class org.springframework.data.hadoop.cascading.CascadingTasklet
 
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
 
convertHbaseAccessException(Exception) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
convertHbaseException(Exception) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils
Converts the given (Hbase) exception to an appropriate exception from org.springframework.dao hierarchy.
convertHiveAccessException(Exception) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Converts the given Hive exception to an appropriate exception from the org.springframework.dao hierarchy.
convertPigAccessException(IOException) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Converts the given Pig exception to an appropriate exception from the org.springframework.dao hierarchy.
convertPigAccessException(ExecException) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Converts the given Pig exception to an appropriate exception from the org.springframework.dao hierarchy.
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.
createFrom(JobConf, Properties) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
Creates a new JobConf based on the given arguments.
createHiveClient() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
 
createHiveClient() - Method in class org.springframework.data.hadoop.hive.HiveTemplate
 
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
 
createPigServer() - Method in class org.springframework.data.hadoop.pig.PigTemplate
 
createResource(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
CustomResourceLoaderRegistrar - Class in org.springframework.data.hadoop.fs
Utility class that overrides the built-in ResourceEditor to allow HdfsResourceLoader to be searched first.
CustomResourceLoaderRegistrar() - Constructor for class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
 

D

decode(String) - Static method in class org.springframework.data.hadoop.util.ResourceUtils
Decodes the given encoded source String into an URI.
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
 
deleteResource(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
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.HiveServerFactoryBean
 
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(Configuration, String) - Constructor for class org.springframework.data.hadoop.fs.DistCp
 
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.
doInHive(HiveClient) - Method in interface org.springframework.data.hadoop.hive.HiveClientCallback
Gets called by HiveTemplate.execute(HiveClientCallback) with an active HiveClient.
doInPig(PigServer) - Method in interface org.springframework.data.hadoop.pig.PigCallback
Gets called by PigTemplate.execute(PigCallback) with an active PigServer.
doInTable(HTableInterface) - Method in interface org.springframework.data.hadoop.hbase.TableCallback
Gets called by HbaseTemplate execute with an active Hbase table.
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.CascadingTasklet
 
execute(String, TableCallback<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Executes the given action against the specified table handling resource management.
execute(String, TableCallback<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
execute(HiveClientCallback<T>) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the action specified by the given callback object within an active HiveClient.
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.hive.HiveTasklet
 
execute(HiveClientCallback<T>) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the action specified by the given callback object within an active HiveClient.
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.mapreduce.JarTasklet
 
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(PigCallback<T>) - Method in interface org.springframework.data.hadoop.pig.PigOperations
Executes the action specified by the given callback object within an active PigServer.
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.pig.PigTasklet
 
execute(PigCallback<T>) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Executes the action specified by the given callback object within an active PigServer.
execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.scripting.ScriptTasklet
 
executeScript(HiveScript) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes a Hive script.
executeScript(Iterable<HiveScript>) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes multiple Hive scripts.
executeScript(HiveScript) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes a Hive script.
executeScript(Iterable<HiveScript>) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes multiple Hive scripts.
executeScript(String) - Method in interface org.springframework.data.hadoop.pig.PigOperations
Executes the given Pig Latin that results in a list of job executions.
executeScript(String, Map<?, ?>) - Method in interface org.springframework.data.hadoop.pig.PigOperations
Executes the given Pig Latin with arguments that results in a list of job executions.
executeScript(PigScript) - Method in interface org.springframework.data.hadoop.pig.PigOperations
Executes the given script identified by location and arguments that results in a list of job executions.
executeScript(Iterable<PigScript>) - Method in interface org.springframework.data.hadoop.pig.PigOperations
Executes multiple scripts that result in a list of job executions.
executeScript(String) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Executes the given Pig Latin that results in a list of job executions.
executeScript(String, Map<?, ?>) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Executes the given Pig Latin with arguments that results in a list of job executions.
executeScript(PigScript) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Executes the given script identified by location and arguments that results in a list of job executions.
executeScript(Iterable<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Executes multiple scripts that result in a list of job executions.
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
 
extractData(ResultScanner) - Method in interface org.springframework.data.hadoop.hbase.ResultsExtractor
Implementations must implement this method to process the entire ResultScanner.

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
 
find(String, String, ResultsExtractor<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Scans the target table, using the given family.
find(String, String, String, ResultsExtractor<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Scans the target table, using the given column family and qualifier.
find(String, Scan, ResultsExtractor<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Scans the target table using the given Scan object.
find(String, String, RowMapper<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Scans the target table, using the given column family.
find(String, String, String, RowMapper<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Scans the target table, using the given column family.
find(String, Scan, RowMapper<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Scans the target table using the given Scan object.
find(String, String, ResultsExtractor<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
find(String, String, String, ResultsExtractor<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
find(String, Scan, ResultsExtractor<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
find(String, String, RowMapper<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
find(String, String, String, RowMapper<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
find(String, Scan, RowMapper<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
findContainingJar(Class<?>) - Static method in class org.springframework.data.hadoop.util.ResourceUtils
Locates the jar (within the classpath) containing the given class.
findContainingJar(ClassLoader, String) - Static method in class org.springframework.data.hadoop.util.ResourceUtils
Locates a jar (within the classpath) containing the given resource.
findPathMatchingResources(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
format(String, boolean) - Static method in class org.springframework.data.hadoop.util.PathUtils
Generates a timed-based path, based on the current date, using the format of Formatter.
format(String) - Static method in class org.springframework.data.hadoop.util.PathUtils
Generates a timed-based path, based on the current date, using the format of Formatter.
format(String, Date) - Static method in class org.springframework.data.hadoop.util.PathUtils
Generates a timed-based path, based on the given date, using the format of Formatter.
format(String, boolean, Date) - Static method in class org.springframework.data.hadoop.util.PathUtils
Generates a timed-based path, based on the given date, using the format of Formatter.
fromJobState(Job.JobState) - Static method in enum org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus
 
fromRunState(int) - Static method in enum org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus
 
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
 
get(String, String, RowMapper<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Gets an individual row from the given table.
get(String, String, String, RowMapper<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Gets an individual row from the given table.
get(String, String, String, String, RowMapper<T>) - Method in interface org.springframework.data.hadoop.hbase.HbaseOperations
Gets an individual row from the given table.
get(String, String, RowMapper<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
get(String, String, String, RowMapper<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
get(String, String, String, String, RowMapper<T>) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
 
getArguments() - Method in class org.springframework.data.hadoop.hive.HiveScript
Returns the arguments associated with this script.
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
 
getCharset() - Method in class org.springframework.data.hadoop.hbase.HbaseAccessor
 
getClassLoader() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
 
getConf() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getConfiguration() - Method in class org.springframework.data.hadoop.hbase.HbaseAccessor
 
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.
getHiveClient() - Method in interface org.springframework.data.hadoop.hive.HiveClientFactory
 
getHomeDirectory() - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
getHost() - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Returns the host.
getHTable(String, Configuration) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils
Retrieves an Hbase table instance identified by its name.
getHTable(String, Configuration, Charset, HTableInterfaceFactory) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils
Retrieves an Hbase table instance identified by its name and charset using the given table factory.
getIdentifier() - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
getIdentifier() - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
getIdentifier() - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
getJobConf(Job) - Static method in class org.springframework.data.hadoop.mapreduce.JobUtils
 
getJobId(Job) - Static method in class org.springframework.data.hadoop.mapreduce.JobUtils
 
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
 
getModifiedTime(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
getModifiedTime(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
getModifiedTime(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
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.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.StreamJobFactoryBean
 
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.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.StreamJobFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
 
getOldJobId(Job) - Static method in class org.springframework.data.hadoop.mapreduce.JobUtils
 
getOrder() - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
 
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
 
getPigServer() - Method in interface org.springframework.data.hadoop.pig.PigServerFactory
 
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(Object) - Static method in class org.springframework.data.hadoop.hbase.HbaseSynchronizationManager
Returns the resource (table) associated with the given key.
getResource() - Method in class org.springframework.data.hadoop.hive.HiveScript
Returns the script resource.
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
 
getRunningJob(Job) - Static method in class org.springframework.data.hadoop.mapreduce.JobUtils
 
getStatus(Job) - Static method in class org.springframework.data.hadoop.mapreduce.JobUtils
Returns the status of the given job.
getTableFactory() - Method in class org.springframework.data.hadoop.hbase.HbaseAccessor
 
getTableNames() - Static method in class org.springframework.data.hadoop.hbase.HbaseSynchronizationManager
Returns the bound tables (by name).
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

hackHadoopStagingOnWin() - Static method in class org.springframework.data.hadoop.util.PermissionUtils
 
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
 
hasResource(Object) - Static method in class org.springframework.data.hadoop.hbase.HbaseSynchronizationManager
Checks whether any resource is bound for the given key.
HbaseAccessor - Class in org.springframework.data.hadoop.hbase
Base class for HbaseTemplate and HbaseInterceptor, defining commons properties such as HTableInterfaceFactory and Configuration.
HbaseAccessor() - Constructor for class org.springframework.data.hadoop.hbase.HbaseAccessor
 
HbaseConfigurationFactoryBean - Class in org.springframework.data.hadoop.hbase
Factory for creating HBase specific configuration.
HbaseConfigurationFactoryBean() - Constructor for class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
 
HbaseInterceptor - Class in org.springframework.data.hadoop.hbase
AOP interceptor that binds a new Hbase table to the thread before a method call, closing and removing it afterwards in case of any method outcome.
HbaseInterceptor() - Constructor for class org.springframework.data.hadoop.hbase.HbaseInterceptor
 
HbaseOperations - Interface in org.springframework.data.hadoop.hbase
Interface that specifies a basic set of Hbase operations, implemented by HbaseTemplate.
HbaseSynchronizationManager - Class in org.springframework.data.hadoop.hbase
Synchronization manager handling the tracking of Hbase resources (specifically tables).
HbaseSynchronizationManager() - Constructor for class org.springframework.data.hadoop.hbase.HbaseSynchronizationManager
 
HbaseSystemException - Exception in org.springframework.data.hadoop.hbase
HBase Data Access exception.
HbaseSystemException(Exception) - Constructor for exception org.springframework.data.hadoop.hbase.HbaseSystemException
 
HbaseTemplate - Class in org.springframework.data.hadoop.hbase
Central class for accessing the HBase API.
HbaseTemplate() - Constructor for class org.springframework.data.hadoop.hbase.HbaseTemplate
 
HbaseTemplate(Configuration) - Constructor for class org.springframework.data.hadoop.hbase.HbaseTemplate
 
HbaseUtils - Class in org.springframework.data.hadoop.hbase
Helper class featuring methods for Hbase table handling and exception translation.
HbaseUtils() - Constructor for class org.springframework.data.hadoop.hbase.HbaseUtils
 
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.
HdfsScriptRunner - Class in org.springframework.data.hadoop.scripting
Hadoop-customized runner that exposes Hadoop specific variables to scripting languages.
HdfsScriptRunner() - Constructor for class org.springframework.data.hadoop.scripting.HdfsScriptRunner
 
HiveClientCallback<T> - Interface in org.springframework.data.hadoop.hive
Callback interface for Hive code.
HiveClientFactory - Interface in org.springframework.data.hadoop.hive
Factory for retrieving a HiveClient instance.
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
 
HiveOperations - Interface in org.springframework.data.hadoop.hive
Interface specifying a basic set of Hive operations.
HiveRunner - Class in org.springframework.data.hadoop.hive
Basic runner for Hive scripts inside a Spring environment.
HiveRunner() - Constructor for class org.springframework.data.hadoop.hive.HiveRunner
 
HiveScript - Class in org.springframework.data.hadoop.hive
Holder class for a Hive script.
HiveScript(Resource) - Constructor for class org.springframework.data.hadoop.hive.HiveScript
Constructs a new HiveScript instance from the given resource.
HiveScript(Resource, Map<?, ?>) - Constructor for class org.springframework.data.hadoop.hive.HiveScript
 
HiveScript(Resource, Properties) - Constructor for class org.springframework.data.hadoop.hive.HiveScript
Constructs a new HiveScript instance.
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
 
HiveTemplate - Class in org.springframework.data.hadoop.hive
Helper class that simplifies Hive data access code.
HiveTemplate() - Constructor for class org.springframework.data.hadoop.hive.HiveTemplate
Constructs a new HiveClient instance.
HiveTemplate(HiveClientFactory) - Constructor for class org.springframework.data.hadoop.hive.HiveTemplate
Constructs a new HiveTemplate instance.

I

initialize(URI, Configuration) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
invoke(MethodInvocation) - Method in class org.springframework.data.hadoop.hbase.HbaseInterceptor
 
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
 
isFinished() - Method in enum org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus
 
isRunning() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
isRunning() - Method in enum org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus
 
isSingleton() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
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.StreamJobFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
isSingleton() - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
 
isStarted() - Method in enum org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus
 

J

JarRunner - Class in org.springframework.data.hadoop.mapreduce
Factory bean for executing Hadoop jars.
JarRunner() - Constructor for class org.springframework.data.hadoop.mapreduce.JarRunner
 
JarTasklet - Class in org.springframework.data.hadoop.mapreduce
Batch tasklet for executing Hadoop jars.
JarTasklet() - Constructor for class org.springframework.data.hadoop.mapreduce.JarTasklet
 
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
 
JobUtils - Class in org.springframework.data.hadoop.mapreduce
Utilities around Hadoop Jobs.
JobUtils() - Constructor for class org.springframework.data.hadoop.mapreduce.JobUtils
 
JobUtils.JobStatus - Enum in org.springframework.data.hadoop.mapreduce
Status of a job.

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
 
mapRow(Result, int) - Method in interface org.springframework.data.hadoop.hbase.RowMapper
 
merge(Configuration, Configuration) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils
Creates a new Configuration by merging the given configurations.
MessageHandlerTap - Class in org.springframework.data.hadoop.cascading.tap.local
SinkTap on top of Spring Integration MessageHandler.
MessageHandlerTap(Scheme<Properties, ?, OutputStream, ?, ?>, MessageHandler) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
MessageSourceTap - Class in org.springframework.data.hadoop.cascading.tap.local
SourceTap for Spring Integration MessageSource.
MessageSourceTap(Scheme<Properties, InputStream, ?, ?, ?>, MessageSource<byte[]>) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
Constructs a new MessageSourceTap instance.
MessageSourceTap(Scheme<Properties, InputStream, ?, ?, ?>, MessageSource<?>, Transformer) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
Constructs a new MessageSourceTap instance.
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(String) - 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
 
openForRead(FlowProcess<Properties>, InputStream) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
openForRead(FlowProcess<Properties>, Resource) - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
openForWrite(FlowProcess<Properties>, OutputStream) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
org.springframework.data.hadoop - package org.springframework.data.hadoop
Package providing integration of Hadoop (and related) technologies with Spring concepts.
org.springframework.data.hadoop.cascading - package org.springframework.data.hadoop.cascading
Support classes for Cascading.
org.springframework.data.hadoop.cascading.tap.local - package org.springframework.data.hadoop.cascading.tap.local
Local Spring-specific Tap for Cascading library.
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.
org.springframework.data.hadoop.util - package org.springframework.data.hadoop.util
Helper classes

P

PathUtils - Class in org.springframework.data.hadoop.util
Utility for generating date-based paths.
PathUtils() - Constructor for class org.springframework.data.hadoop.util.PathUtils
 
PermissionUtils - Class in org.springframework.data.hadoop.util
Simple utility class that fixes the File permission problem on Windows.
PermissionUtils() - Constructor for class org.springframework.data.hadoop.util.PermissionUtils
 
PigCallback<T> - Interface in org.springframework.data.hadoop.pig
Callback interface for Pig code.
PigContextFactoryBean - Class in org.springframework.data.hadoop.pig
Factory for creating a PigContext instance.
PigContextFactoryBean() - Constructor for class org.springframework.data.hadoop.pig.PigContextFactoryBean
 
PigOperations - Interface in org.springframework.data.hadoop.pig
Interface specifying a basic set of Pig operations.
PigRunner - Class in org.springframework.data.hadoop.pig
Basic runner of Pig scripts inside a Spring environment.
PigRunner() - Constructor for class org.springframework.data.hadoop.pig.PigRunner
 
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.
PigScript(Resource, Map<?, ?>) - Constructor for class org.springframework.data.hadoop.pig.PigScript
Constructs a new PigScript instance.
PigServerFactory - Interface in org.springframework.data.hadoop.pig
Factory for retrieving a PigServer 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
 
PigTemplate - Class in org.springframework.data.hadoop.pig
Helper class that simplifies Pig data access code.
PigTemplate() - Constructor for class org.springframework.data.hadoop.pig.PigTemplate
Constructs a new PigTemplate instance.
PigTemplate(PigServerFactory) - Constructor for class org.springframework.data.hadoop.pig.PigTemplate
Constructs a new PigTemplate instance.
postProcess(Map<String, Object>) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptRunner
 
postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
 
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
 

Q

query(String) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL that results in a list of objects.
query(String, Map<?, ?>) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL using the list of arguments, expecting a list of objects.
query(String) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL that results in a list of objects.
query(String, Map<?, ?>) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL using the list of arguments, expecting a list of objects.
queryForInt(String) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL that results in a single int value.
queryForInt(String, Map<?, ?>) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL using the list of arguments, that results in a single int value.
queryForInt(String) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL that results in a single int value.
queryForInt(String, Map<?, ?>) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL using the list of arguments, that results in a single int value.
queryForLong(String) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL that results in a single long value.
queryForLong(String, Map<?, ?>) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL using the list of arguments, that results in a single long value.
queryForLong(String) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL that results in a single long value.
queryForLong(String, Map<?, ?>) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL using the list of arguments, that results in a single long value.
queryForString(String) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL that results in a single object.
queryForString(String, Map<?, ?>) - Method in interface org.springframework.data.hadoop.hive.HiveOperations
Executes the given HiveQL using the list of arguments, that results in a single object.
queryForString(String) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL that results in a single object.
queryForString(String, Map<?, ?>) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Executes the given HiveQL using the list of arguments, that results in a single object.

R

releaseTable(String, HTableInterface) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils
Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).
releaseTable(String, HTableInterface, HTableInterfaceFactory) - Static method in class org.springframework.data.hadoop.hbase.HbaseUtils
Releases (or closes) the given table, created via the given configuration if it is not managed externally (or bound to the thread).
rename(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
rename(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
ResourceTap - Class in org.springframework.data.hadoop.cascading.tap.local
SourceTap for Spring's Resource abstraction.
ResourceTap(Scheme<Properties, Resource, ?, ?, ?>, Resource) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
Constructs a new ResourceTap instance.
ResourceTap(Scheme<Properties, Resource, ?, ?, ?>, Resource[]) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
Constructs a new ResourceTap instance.
ResourceUtils - Class in org.springframework.data.hadoop.util
Utility class for dealing or location resources for Hadoop jobs.
ResourceUtils() - Constructor for class org.springframework.data.hadoop.util.ResourceUtils
 
ResultsExtractor<T> - Interface in org.springframework.data.hadoop.hbase
Callback handling scanner results.
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
 
RowMapper<T> - Interface in org.springframework.data.hadoop.hbase
Callback for mapping rows of a ResultScanner on a per-row basis.

S

ScriptEvaluator - Interface in org.springframework.data.hadoop.scripting
Script evaluator.
ScriptTasklet - Class in org.springframework.data.hadoop.scripting
Scripting tasklet.
ScriptTasklet() - Constructor for class org.springframework.data.hadoop.scripting.ScriptTasklet
 
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).
setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
 
setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptRunner
 
setAutoFlush(boolean) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
Sets the auto flush.
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
 
setBeanClassLoader(ClassLoader) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
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
 
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.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.
setCreateSymlink(boolean) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
Indicates whether to create symlinks or not.
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.
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.
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.
setExecutor(Executor) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
Sets the executor for starting the server (which is a blocking operation).
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') URI.
setFlows(Collection<Flow>) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
Sets the flows.
setGroupingComparator(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job grouping comparator class.
setHiveClientFactory(HiveClientFactory) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Sets the HiveClient factory.
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(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.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).
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.
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.
setKey(String) - 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.
setListeners(Collection<CascadeListener>) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
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.
setLoader(ResourcePatternResolver) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
 
setLocalEntries(Collection<Resource>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
Sets the local entries to be added to the distributed cache.
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.
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.
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
 
setParallelism(Integer) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the parallelism.
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.
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.
setPigFactory(PigServerFactory) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Sets the PigServer factory.
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.
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.
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
 
setResourceLoader(ResourceLoader) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
 
setResourceLoader(ResourceLoader) - Method in class org.springframework.data.hadoop.pig.PigTemplate
 
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.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).
setScriptCallback(Callable<Object>) - Method in class org.springframework.data.hadoop.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<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the scripts to execute at startup.
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.
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.
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.
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.
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
 
setTraps(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the traps.
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.
setUser(String) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the user impersonation (optional) for executing Pig jobs.
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.
setVerifyChecksum(boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
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
 
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).
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.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() - 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

TableCallback<T> - Interface in org.springframework.data.hadoop.hbase
Callback interface for Hbase code.
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.hive.HiveScript
 
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
 

U

unbindResource(String) - Static method in class org.springframework.data.hadoop.hbase.HbaseSynchronizationManager
Unbinds a resource for the given key from the current thread.
unbindResourceIfPossible(Object) - Static method in class org.springframework.data.hadoop.hbase.HbaseSynchronizationManager
Unbinds a resource for the given key from the current thread.

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.mapreduce.JobUtils.JobStatus
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.mapreduce.JobUtils.JobStatus
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 B C D E F G H I J L M O P Q R S T U V