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

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.mapreduce.ToolTasklet

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

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.

doWrite(List<? extends T>) - Method in class org.springframework.data.hadoop.fs.HdfsItemWriter

Performs the actual write to the store via the template.

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

HdfsItemWriter<T> - Class in org.springframework.data.hadoop.fs

An ItemWriter implementation used to write the incoming items to HDFS.

HdfsItemWriter(FileSystem, Serializer<T>, String) - Constructor for class org.springframework.data.hadoop.fs.HdfsItemWriter

Constructor

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

isHadoop2X() - Static method in class org.springframework.data.hadoop.util.VersionUtils

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(ExecutionContext) - Method in class org.springframework.data.hadoop.fs.HdfsItemWriter

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.

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

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

Sets the table factory.

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

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

Sets the tail.

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

Sets the tails.

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.

update(ExecutionContext) - Method in class org.springframework.data.hadoop.fs.HdfsItemWriter

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.

VersionUtils - Class in org.springframework.data.hadoop.util

Simple utility class that provides methods to handle different versions of Hadoop.

VersionUtils() - Constructor for class org.springframework.data.hadoop.util.VersionUtils

W

write(List<? extends T>) - Method in class org.springframework.data.hadoop.fs.HdfsItemWriter

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