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

A

addProperties(Configuration, Properties) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils

Adds the specified properties to the given Configuration object.

afterPropertiesSet() - Method in class org.springframework.data.hadoop.batch.HdfsItemReader

After properties set.

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

afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner

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

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

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

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

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

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

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

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

afterPropertiesSet() - Method in class org.springframework.data.hadoop.hive.HiveTasklet

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

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

afterPropertiesSet() - Method in class org.springframework.data.hadoop.mapreduce.JobTasklet

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

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

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

afterPropertiesSet() - Method in class org.springframework.data.hadoop.pig.PigTasklet

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

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

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

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

append(Path, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

append(String, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

asProperties(Configuration) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils

Returns a static Properties copy of the given configuration.

C

CascadeFactoryBean - Class in org.springframework.data.hadoop.cascading

Factory for declarative Cascade creation.

CascadeFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.CascadeFactoryBean

CascadeRunner - Class in org.springframework.data.hadoop.cascading

Simple runner for executing Cascades or Flows.

CascadeRunner() - Constructor for class org.springframework.data.hadoop.cascading.CascadeRunner

CascadeTasklet - Class in org.springframework.data.hadoop.cascading

Batch tasklet for executing a Cascade or a Flow as part of a job.

CascadeTasklet() - Constructor for class org.springframework.data.hadoop.cascading.CascadeTasklet

cat(String) - Method in class org.springframework.data.hadoop.fs.FsShell

cat(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

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

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

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

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

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

chmod(Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell

chmod(Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

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

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

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

chmodr(Integer, String) - Method in class org.springframework.data.hadoop.fs.FsShell

chmodr(Integer, String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

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

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

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

close() - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

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

ConfigurationFactoryBean - Class in org.springframework.data.hadoop.configuration

FactoryBean for creating Configuration instances.

ConfigurationFactoryBean() - Constructor for class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean

ConfigurationUtils - Class in org.springframework.data.hadoop.configuration

Reusable utility class for common Configuration operations.

ConfigurationUtils() - Constructor for class org.springframework.data.hadoop.configuration.ConfigurationUtils

copy(EnumSet<DistCp.Preserve>, Boolean, Boolean, Boolean, Boolean, String...) - Method in class org.springframework.data.hadoop.fs.DistCp

Copy operation.

copy(EnumSet<DistCp.Preserve>, Boolean, Boolean, String, Integer, Boolean, Boolean, Boolean, Long, Long, String, String...) - Method in class org.springframework.data.hadoop.fs.DistCp

Copies the given resources using the given parameters.

copy(Boolean, Boolean, Boolean, Boolean, Boolean, Boolean, Boolean, String, Integer, Boolean, Boolean, Boolean, Long, Long, String, String...) - Method in class org.springframework.data.hadoop.fs.DistCp

Copies the given resources using the given parameters.

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

Basic copy operation, between a source and a destination using the defaults.

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

Basic copy operation, between a source and a destination using the defaults.

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

DistCopy using a command-line style (arguments are specified as Strings).

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

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

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

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

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

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

copyFromLocalFile(boolean, boolean, Path[], Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

copyFromLocalFile(boolean, boolean, String[], String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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

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

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

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

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

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

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

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

count(String) - Method in class org.springframework.data.hadoop.fs.FsShell

count(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

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

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

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

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

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

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

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

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

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

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

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

create(String, boolean, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(Path, boolean, int) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(Path, boolean, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(String, boolean, int, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(Path, boolean, int, short, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(String, boolean, int, short, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(Path, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(String, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

create(String, FsPermission, boolean, int, short, long, Progressable) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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

Creates a configuration instance potentially using the existing one (passed as an argument - which can be null).

createFrom(Configuration, Properties) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils

Creates a new Configuration based on the given arguments.

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

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

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

D

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

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

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

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

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

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

destroy() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner

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

destroy() - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

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

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

determineRootDir(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

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

Exposes the Hadoop command-line distcp as an embeddable API.

DistCp(Configuration) - Constructor for class org.springframework.data.hadoop.fs.DistCp

Constructs a new DistCp instance.

DistCp.Preserve - Enum in org.springframework.data.hadoop.fs

Enumeration for the possible attributes that can be preserved by a copy operation.

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

Factory for easy declarative configuration of a DistributedCache.

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

DistributedCacheFactoryBean.CacheEntry - Class in org.springframework.data.hadoop.fs

Class describing an entry of the distributed cache.

DistributedCacheFactoryBean.CacheEntry(DistributedCacheFactoryBean.CacheEntry.EntryType, String) - Constructor for class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry

Constructs a new CacheEntry instance.

DistributedCacheFactoryBean.CacheEntry.EntryType - Enum in org.springframework.data.hadoop.fs

A distributed cache entry type.

du(String) - Method in class org.springframework.data.hadoop.fs.FsShell

du(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

dus(String) - Method in class org.springframework.data.hadoop.fs.FsShell

dus(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

E

equals(Object) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

evaluate(ScriptSource) - Method in interface org.springframework.data.hadoop.scripting.ScriptEvaluator

evaluate(ScriptSource, Map<String, Object>) - Method in interface org.springframework.data.hadoop.scripting.ScriptEvaluator

EvaluationPolicy - Enum in org.springframework.data.hadoop.scripting

The policy for evaluating a script.

execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.cascading.CascadeTasklet

execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.hive.HiveTasklet

execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.mapreduce.JobTasklet

execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet

execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.pig.PigTasklet

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

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

expunge() - Method in class org.springframework.data.hadoop.fs.FsShell

F

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

FactoryBean for creating Hadoop FileSystem instances.

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

findPathMatchingResources(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

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

HDFS FileSystem Shell supporting the 'hadoop fs/dfs [x]' commands as methods.

FsShell(Configuration) - Constructor for class org.springframework.data.hadoop.fs.FsShell

Constructs a new FsShell instance.

FsShell(Configuration, FileSystem) - Constructor for class org.springframework.data.hadoop.fs.FsShell

Constructs a new FsShell instance.

G

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

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

getArguments() - Method in class org.springframework.data.hadoop.pig.PigScript

Returns the arguments associated with this script.

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

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

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

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

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

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

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

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

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

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

getFileBlockLocations(FileStatus, long, long) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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

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

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

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

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

Returns the Hadoop file system used by this resource loader.

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

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

Returns the host.

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

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

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

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

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

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

getObject() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

getObjectType() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Returns the port.

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

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

getResource(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

getResource() - Method in class org.springframework.data.hadoop.pig.PigScript

Returns the script resource.

getResources(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader

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

Returns the timeout.

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

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

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

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

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

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

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

H

HadoopException - Exception in org.springframework.data.hadoop

Core Hadoop Exception.

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

Constructs a new HadoopException instance.

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

Constructs a new HadoopException instance.

HadoopFlowFactoryBean - Class in org.springframework.data.hadoop.cascading

Factory for declarative HadoopFlow creation.

HadoopFlowFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

HadoopSecurityException - Exception in org.springframework.data.hadoop

Security-related exception generated by Hadoop.

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

Constructs a new HadoopSecurityException instance.

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

Constructs a new HadoopSecurityException instance.

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

HbaseConfigurationFactoryBean - Class in org.springframework.data.hadoop.hbase

Factory for creating HBase specific configuration.

HbaseConfigurationFactoryBean() - Constructor for class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean

HdfsItemReader<T> - Class in org.springframework.data.hadoop.batch

Spring Batch ItemReader implementation for Hadoop FileSystem.

HdfsItemReader(Configuration) - Constructor for class org.springframework.data.hadoop.batch.HdfsItemReader

Instantiates a new hdfs item reader.

HdfsItemReader(FileSystem) - Constructor for class org.springframework.data.hadoop.batch.HdfsItemReader

Instantiates a new hdfs item reader.

HdfsItemReader(HdfsResourceLoader) - Constructor for class org.springframework.data.hadoop.batch.HdfsItemReader

Instantiates a new hdfs item reader.

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

Spring ResourceLoader over Hadoop FileSystem.

HdfsResourceLoader(Configuration) - Constructor for class org.springframework.data.hadoop.fs.HdfsResourceLoader

Constructs a new HdfsResourceLoader instance.

HdfsResourceLoader(Configuration, URI, String) - Constructor for class org.springframework.data.hadoop.fs.HdfsResourceLoader

Constructs a new HdfsResourceLoader instance.

HdfsResourceLoader(Configuration, URI) - Constructor for class org.springframework.data.hadoop.fs.HdfsResourceLoader

Constructs a new HdfsResourceLoader instance.

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

Constructs a new HdfsResourceLoader instance.

HdfsScriptFactoryBean - Class in org.springframework.data.hadoop.scripting

Hadoop-customized factory that exposes Hadoop specific variables to scripting languages.

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

HiveClientFactoryBean - Class in org.springframework.data.hadoop.hive

FactoryBean for easy declaration and creation of a HiveClient using ThriftHive.

HiveClientFactoryBean() - Constructor for class org.springframework.data.hadoop.hive.HiveClientFactoryBean

HiveServerFactoryBean - Class in org.springframework.data.hadoop.hive

FactoryBean for easy declaration and creation of an embeddable Hive server.

HiveServerFactoryBean() - Constructor for class org.springframework.data.hadoop.hive.HiveServerFactoryBean

HiveTasklet - Class in org.springframework.data.hadoop.hive

Hive tasklet running Hive scripts on demand, against a HiveClient.

HiveTasklet() - Constructor for class org.springframework.data.hadoop.hive.HiveTasklet

I

initialize(URI, Configuration) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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

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

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

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

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

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

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

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

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

isSingleton() - Method in class org.springframework.data.hadoop.cascading.CascadeRunner

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

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

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

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

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

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

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

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

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

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

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

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

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

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

J

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

Factory bean for creating a Hadoop Map-Reduce job.

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

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

Simple runner for submitting Hadoop jobs sequentially.

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

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

Batch tasklet for executing one Hadoop job.

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

L

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

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

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

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

listStatus(Path[]) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

listStatus(String[]) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

listStatus(Path[], PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

listStatus(String[], PathFilter) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

ls(String) - Method in class org.springframework.data.hadoop.fs.FsShell

ls(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

lsr(String) - Method in class org.springframework.data.hadoop.fs.FsShell

lsr(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

M

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

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

MapReduceFlowFactoryBean - Class in org.springframework.data.hadoop.cascading

Factory for declarative MapReduceFlow creation.

MapReduceFlowFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean

merge(Configuration, Configuration) - Static method in class org.springframework.data.hadoop.configuration.ConfigurationUtils

Creates a new Configuration by merging the given configurations.

mkdir(String) - Method in class org.springframework.data.hadoop.fs.FsShell

mkdir(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

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

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

moveFromLocalFile(Path[], Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

moveFromLocalFile(String[], String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem

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

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

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

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

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

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

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

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

O

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

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

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

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

org.springframework.data.hadoop - package org.springframework.data.hadoop

Package providing integration of Hadoop (and related) technologies with Spring concepts.

org.springframework.data.hadoop.batch - package org.springframework.data.hadoop.batch

Package providing integration with Spring Batch.

org.springframework.data.hadoop.cascading - package org.springframework.data.hadoop.cascading

Support classes for Cascading.

org.springframework.data.hadoop.configuration - package org.springframework.data.hadoop.configuration

Support classes for configuring Hadoop.

org.springframework.data.hadoop.fs - package org.springframework.data.hadoop.fs

Hadoop FileSystem supporting classes.

org.springframework.data.hadoop.hbase - package org.springframework.data.hadoop.hbase

Package providing integration with Apache HBase.

org.springframework.data.hadoop.hive - package org.springframework.data.hadoop.hive

Package providing integration with Apache Hive.

org.springframework.data.hadoop.mapreduce - package org.springframework.data.hadoop.mapreduce

Support classes for Hadoop core Map Reduce functionality such as job (whether vanilla Map-Reduce or streaming).

org.springframework.data.hadoop.pig - package org.springframework.data.hadoop.pig

Package providing integration with Apache Pig.

org.springframework.data.hadoop.scripting - package org.springframework.data.hadoop.scripting

Support classes for scripting Hadoop.

P

PigContextFactoryBean - Class in org.springframework.data.hadoop.pig

Factory for creating a PigContext instance.

PigContextFactoryBean() - Constructor for class org.springframework.data.hadoop.pig.PigContextFactoryBean

PigScript - Class in org.springframework.data.hadoop.pig

Holder class for a pig script.

PigScript(Resource) - Constructor for class org.springframework.data.hadoop.pig.PigScript

Constructs a new PigScript instance from the given resource.

PigScript(Resource, Properties) - Constructor for class org.springframework.data.hadoop.pig.PigScript

Constructs a new PigScript instance.

PigServerFactoryBean - Class in org.springframework.data.hadoop.pig

Factory for creating a PigServer instance.

PigServerFactoryBean() - Constructor for class org.springframework.data.hadoop.pig.PigServerFactoryBean

PigTasklet - Class in org.springframework.data.hadoop.pig

Pig tasklet.

PigTasklet() - Constructor for class org.springframework.data.hadoop.pig.PigTasklet

postProcess(Map<String, Object>) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptFactoryBean

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

processJob(Job) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean

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

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

R

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

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

rm(String) - Method in class org.springframework.data.hadoop.fs.FsShell

rm(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

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

rmr(String) - Method in class org.springframework.data.hadoop.fs.FsShell

rmr(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

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

S

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

Script evaluator.

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

setArchive(String[]) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean

Sets the job archives.

setArguments(String[]) - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner

Sets the arguments.

setArguments(String[]) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet

Sets the arguments.

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

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

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

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

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

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

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

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

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

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

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

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

Sets the environment for the commands to be executed.

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

Sets the job codec class.

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

Sets the job combiner class.

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

Sets the job combiner.

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

Indicates whether the job output should be compressed or not.

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

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

Sets the configuration.

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

Sets the configuration.

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

Sets the configuration.

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

Sets the parent configuration.

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

Sets the Hadoop configuration for the cache.

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

Sets the Hadoop configuration for this file system.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

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

Sets the Hadoop configuration to use.

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

Sets the configuration.

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

Sets the configuration.

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

Sets the Hadoop configuration to use.

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

Indicates whether to create symlinks or not.

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

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

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

Sets the delete sink on init.

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

Sets the entries to be added to the distributed cache.

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

Sets the execution type.

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

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

setFile(String[]) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean

Sets the job files.

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

Sets the Hadoop file system for this cache.

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

Sets the flows.

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

Sets the job grouping comparator class.

setHiveClient(HiveClient) - Method in class org.springframework.data.hadoop.hive.HiveTasklet

Sets the hive client for this tasklet.

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

Sets the server host.

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

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

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

Sets the job input format class.

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

Sets the job input format.

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

Sets the job input path.

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

Sets the job input paths.

setInputPaths(List<String>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean

Sets the job input paths.

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

Sets the job jar.

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

Determines the job jar based on the given class.

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

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

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

Sets the job to execute.

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

Sets the job name.

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

Sets the job pooling interval.

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

Sets the job priority.

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

Sets the Jobs to run.

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

Sets the job tracker.

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

Sets the job key class.

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

Sets the last alias.

setLibJar(String[]) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean

Sets the job jar libraries.

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

Sets the listeners.

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

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

setLocation(String) - Method in class org.springframework.data.hadoop.batch.HdfsItemReader

Sets the location.

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

Sets the job map key class.

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

Sets the job mapper class.

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

Sets the job mapper.

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

Sets the job map value class.

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

Sets the max concurrent steps.

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

Sets the maximum number of threads serving this server.

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

Sets the minimum number of threads serving this server.

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

Sets the job name.

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

Sets the number of reduce task for this job.

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

Sets the job number of reducer tasks.

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

Sets the job output format class.

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

Sets the job output format.

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

Sets the job output path.

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

Sets the job output paths.

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

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

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

Sets the parallelism.

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

Sets the job partitioner class.

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

Sets the job partitioner.

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

Sets the paths to skip.

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

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

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

Sets the PigContext to use.

setPigServer(PigServer) - Method in class org.springframework.data.hadoop.pig.PigTasklet

Sets the pig server instance used by this tasklet.

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

Sets the server port.

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

Sets the server port.

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

Sets the properties.

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

Sets the properties.

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

Sets the properties.

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

Sets the configuration properties.

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

Sets the configuration properties.

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

Sets the configuration properties.

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

The configuration properties to set for this job.

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

Sets the configuration properties to use.

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

Sets the properties.

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

Sets the properties.

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

Sets the configuration properties.

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

Sets the job reducer class.

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

Sets the job reducer.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Sets the configuration resources.

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

Sets the run at startup.

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

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

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

Sets the run at startup.

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

Sets the scripts to execute once the client connects.

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

Sets the scripts to be executed by this tasklet.

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

Sets the scripts to execute at startup.

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

Sets the pig scripts to be executed by this tasklet.

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

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

Sets the sinks.

setSkipStrategy(FlowSkipStrategy) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the skip strategy.

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

Sets the job sort comparator class.

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

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

Sets the sources.

setStepStrategy(FlowStepStrategy) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean

Sets the step strategy.

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

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

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

Sets the tail.

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

Sets the tails.

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

Sets the connection timeout.

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

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

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

Sets the tool.

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

Sets the tool.

setToolClass(Class<? extends Tool>) - Method in class org.springframework.data.hadoop.mapreduce.ToolRunner

Sets the tool class.

setToolClass(Class<? extends Tool>) - Method in class org.springframework.data.hadoop.mapreduce.ToolTasklet

Sets the tool class.

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

Sets the traps.

setUnitOfWork(UnitOfWork<CascadingStats>) - Method in class org.springframework.data.hadoop.cascading.CascadeRunner

Sets the unit of work.

setUnitOfWork(UnitOfWork<CascadingStats>) - Method in class org.springframework.data.hadoop.cascading.CascadeTasklet

Sets the unit of work.

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

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

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

Indicates whether each statement should be validated or not.

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

Indicates whether the job input/output paths should be validated (default) before the job is submitted.

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

Sets the job value class.

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

setWaitForJob(boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobTasklet

Indicates whether the tasklet should return for the job to complete (default) after submission or not.

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

Indicates whether the runner should wait for the jobs to finish (the default) or not.

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

Sets the job working directory.

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

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

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

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

Constructs a new SimplerFileSystem instance.

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

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

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

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

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

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

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

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

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

Factory bean focused on creating streaming jobs.

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

T

test(String) - Method in class org.springframework.data.hadoop.fs.FsShell

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

text(String) - Method in class org.springframework.data.hadoop.fs.FsShell

text(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

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

Wrapper around ToolRunner allowing for an easier configuration and execution of Tool instances inside Spring.

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

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

Tasklet for executing Hadoop Tools.

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

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

toString() - Method in class org.springframework.data.hadoop.pig.PigScript

touchz(String) - Method in class org.springframework.data.hadoop.fs.FsShell

touchz(String...) - Method in class org.springframework.data.hadoop.fs.FsShell

V

valueOf(String) - Static method in enum org.springframework.data.hadoop.fs.DistCp.Preserve

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry.EntryType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.data.hadoop.scripting.EvaluationPolicy

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.springframework.data.hadoop.fs.DistCp.Preserve

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry.EntryType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.data.hadoop.scripting.EvaluationPolicy

Returns an array containing the constants of this enum type, in the order they are declared.

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