Spring for Apache Hadoop
A B C D E F G H I J K L M N O P Q R S T U V W 

S

schema - Variable in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
 
ScriptEvaluator - Interface in org.springframework.data.hadoop.scripting
Script evaluator.
ScriptParser - Class in org.springframework.data.hadoop.config
Namespace parser for hdp:script.
ScriptParser() - Constructor for class org.springframework.data.hadoop.config.ScriptParser
 
ScriptTasklet - Class in org.springframework.data.hadoop.batch.scripting
Scripting tasklet.
ScriptTasklet() - Constructor for class org.springframework.data.hadoop.batch.scripting.ScriptTasklet
 
SequenceFileWriterHolder<T extends java.io.Closeable> - Class in org.springframework.data.hadoop.store.support
Holder object for SequenceFile writer.
SequenceFileWriterHolder() - Constructor for class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder
Instantiates a new sequence file writer holder.
SequenceFileWriterHolder(T) - Constructor for class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder
Instantiates a new sequence file writer holder.
SequenceFileWriterHolder(T, Path) - Constructor for class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder
Instantiates a new sequence file writer holder.
setAllowNullValues(boolean) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
 
setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.scripting.HdfsScriptRunner
 
setApplicationContext(ApplicationContext) - Method in class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests
 
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher
 
setAutoFlush(boolean) - Method in class org.springframework.data.hadoop.hbase.HbaseTemplate
Sets the auto flush.
setAutoStart(boolean) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean
Set whether cluster should be started automatically by this factory instance.
setAutoStartup(boolean) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
Indicates whether the Hive client should start automatically (default) or not.
setAutoStartup(boolean) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Sets the auto startup.
setBasePath(String) - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
The base path for the datasets in this repository.
setBeanClassLoader(ClassLoader) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationConfiguration
 
setBeanClassLoader(ClassLoader) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
 
setBeanClassLoader(ClassLoader) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
 
setBeanFactory(BeanFactory) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
 
setBeanFactory(BeanFactory) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
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
 
setBuilder(B) - Method in class org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerAdapter
Sets the AnnotationBuilder to be used.
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.
setCluster(HadoopCluster) - Method in class org.springframework.data.hadoop.test.support.ConfigurationDelegatingFactoryBean
setClusterId(String) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean
Sets the cluster id.
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.
setCodecInfo(CodecInfo) - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
 
setCodecInfo(CodecInfo) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
 
setCodecInfo(CodecInfo) - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy
Sets the codec info.
setCodecInfo(CodecInfo) - Method in class org.springframework.data.hadoop.store.support.OutputContext
Sets the codec info.
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
 
setConf(Configuration) - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
The Hadoop configuraton to be used
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.
setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
Sets the configuration.
setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests
Sets the Configuration.
setConfigurers(List<AnnotationConfigurer<O, B>>) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationConfiguration
Sets the configurers.
setCreateSymlink(boolean) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
Indicates whether to create symlinks or not.
setCSVProperty(Element, BeanDefinitionBuilder, String, String) - Static method in class org.springframework.data.hadoop.config.NamespaceUtils
 
setCSVReferenceProperty(Element, BeanDefinitionBuilder, String, String) - Static method in class org.springframework.data.hadoop.config.NamespaceUtils
 
setDatasetDefinitions(Collection<DatasetDefinition>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
The list of DatasetDefinitions to use for this template.
setDatasetRepositoryFactory(DatasetRepositoryFactory) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
The DatasetRepositoryFactory to use for this template.
setDefaultDatasetDefinition(DatasetDefinition) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
The default DatasetDefinition to use for this template.
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).
setEnabled(boolean) - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
Sets if this strategy is enabled.
setEncoding(String) - Method in class org.springframework.data.hadoop.hbase.HbaseAccessor
Sets the encoding.
setEnd(long) - Method in class org.springframework.data.hadoop.store.support.InputContext
 
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).
setExecutor(Executor) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Sets the TaskExecutor used for executing the Hadoop job.
setFileNamingStrategy(FileNamingStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputContext
Sets the file naming strategy.
setFileNamingStrategy(FileNamingStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Sets the file naming strategy.
setFileNamingStrategyFactory(FileNamingStrategyFactory<FileNamingStrategy>) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Sets the file naming strategy factory.
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') and ('fs.defaultFS') URI for HadoopV1 and HadoopV2 respectively.
setFormat(String) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
setGroupingComparator(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job grouping comparator class.
setHadoopCluster(HadoopCluster) - Method in class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests
Sets the HadoopCluster
setHandleNoprefix(boolean) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
Sets the handle noprefix.
setHiveClientFactory(HiveClientFactory) - Method in class org.springframework.data.hadoop.hive.HiveExecutor
Sets the hive client for this tasklet.
setHiveClientFactory(HiveClientFactory) - Method in class org.springframework.data.hadoop.hive.HiveTemplate
Sets the HiveClient factory.
setHiveTemplate(HiveOperations) - Method in class org.springframework.data.hadoop.hive.HiveExecutor
Sets the hive template.
setHost(String) - Method in class org.springframework.data.hadoop.hive.HiveClientFactoryBean
Sets the server host.
setId(String) - Method in class org.springframework.data.hadoop.test.support.ClusterInfo
 
setId(String) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterDelegatingFactoryBean
 
setIdleTimeout(long) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Sets the idle timeout.
setIdleTimeout(long) - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
Sets the idle timeout.
setImportMetadata(AnnotationMetadata) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationConfiguration
 
setInitialDelay(long) - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
Specify the delay for the initial execution.
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.
setInWritingPrefix(String) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Sets the in writing prefix.
setInWritingPrefix(String) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Sets the in writing prefix.
setInWritingSuffix(String) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Sets the in writing suffix.
setInWritingSuffix(String) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Sets the in writing suffix.
setItems(List<? extends S>) - Method in class org.springframework.data.hadoop.store.support.OrderedComposite
Public setter for the listeners.
setJar(Resource) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job jar (which might not be on the classpath).
setJarByClass(Class<?>) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Determines the job jar (available on the classpath) based on the given class.
setJob(Job) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Sets the job to execute.
setJobName(String) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the job name.
setJobNames(String...) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Sets the jobs to execute by (bean) name.
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.JobExecutor
Sets the jobs to execute.
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 for HadoopV1.
setKey(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job key class.
setKillJobAtShutdown(boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Indicates whether the configured jobs should be 'killed' when the application shuts down (default) or not.
setLastAlias(String) - Method in class org.springframework.data.hadoop.pig.PigContextFactoryBean
Sets the last alias.
setLength(long) - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
setLength(long) - Method in class org.springframework.data.hadoop.store.split.StaticLengthSplitter
Sets the split length.
setLoadDefaults(boolean) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
Indicates whether to load the defaults (the default) or not for this configuration.
setLoader(ResourcePatternResolver) - Method in class org.springframework.data.hadoop.fs.CustomResourceLoaderRegistrar
Sets the resource pattern loader.
setLocalEntries(Collection<Resource>) - Method in class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
Sets the local entries to be added to the distributed cache.
setMainClass(String) - Method in class org.springframework.data.hadoop.mapreduce.JarExecutor
Sets the target class by name.
setMapKey(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job map key class.
setMapper(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job mapper class.
setMapper(String) - Method in class org.springframework.data.hadoop.mapreduce.StreamJobFactoryBean
Sets the job mapper.
setMapValue(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job map value class.
setMaxOpenAttempts(int) - Method in class org.springframework.data.hadoop.store.output.AbstractDataStreamWriter
Sets the max open attempts trying to find a suitable path for output stream.
setMaxOpenAttempts(int) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Sets the max open attempts.
setMaxSplitSize(long) - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Sets the maximum split size.
setMaxThreads(int) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
Sets the maximum number of threads serving this server.
setMinSplitSize(long) - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Sets the minimum split size.
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.
setName(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
Sets the file name part.
setNodes(int) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterDelegatingFactoryBean
 
setNodes(int) - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean
Sets the number of nodes.
setNodes(int) - Method in class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster
Sets a number of nodes for cluster.
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.
setNumDfs(int) - Method in class org.springframework.data.hadoop.test.support.ClusterInfo
 
setOrder(int) - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
Sets the order.
setOrder(int) - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy
Sets the order.
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.
setOverwrite(boolean) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Sets the flag indicating if written files may be overwritten.
setOverwrite(boolean) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Sets the flag indicating if written files may be overwritten.
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.
setPartitionStrategy(PartitionStrategy) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
setPath(Path) - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
Sets the path.
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
 
setPhase(int) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Sets the phase.
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.PigExecutor
Sets the pig server instance used by this class.
setPigFactory(PigServerFactory) - Method in class org.springframework.data.hadoop.pig.PigTemplate
Sets the PigServer factory.
setPigTemplate(PigOperations) - Method in class org.springframework.data.hadoop.pig.PigExecutor
Sets the pig template used by this class.
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.
setPosition(long) - Method in class org.springframework.data.hadoop.store.support.InputContext
 
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.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.
setPrefix(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
Sets the prefix preceding rolling number part.
setPrefix(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
Sets the prefix preceding name part.
setPrefix(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
Sets the prefix preceding uuid part.
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.
setPropertyValue(Element, BeanDefinitionBuilder, String, String) - Static method in class org.springframework.data.hadoop.config.NamespaceUtils
 
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
 
setResourcePatternResolver(ResourcePatternResolver) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
Sets the resource pattern resolver.
setResources(Set<Resource>) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
Sets the configuration resources.
setRmManagerUri(String) - Method in class org.springframework.data.hadoop.configuration.ConfigurationFactoryBean
Sets the Yarn resource manager ('yarn.resourcemanager.address') URI for HadoopV2.
setRolloverSize(long) - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
Sets the rollover size.
setRolloverStrategy(RolloverStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputContext
Sets the rollover strategy.
setRolloverStrategy(RolloverStrategy) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Sets the rollover strategy.
setRolloverStrategyFactory(RolloverStrategyFactory<RolloverStrategy>) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Sets the rollover strategy factory.
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.batch.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<HiveScript>) - Method in class org.springframework.data.hadoop.hive.HiveExecutor
Sets the scripts to be executed by this tasklet.
setScripts(Collection<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigExecutor
Sets the pig scripts to be executed by this class.
setScripts(Collection<PigScript>) - Method in class org.springframework.data.hadoop.pig.PigServerFactoryBean
Sets the scripts to execute at startup.
setSharedObject(Class<C>, C) - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder
Sets an object that is shared by multiple AnnotationConfigurer.
setSlop(double) - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Sets the slop factor.
setSortComparator(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job sort comparator class.
setSplits(int) - Method in class org.springframework.data.hadoop.store.split.StaticBlockSplitter
Sets the splits count.
setStart(long) - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
setStart(long) - Method in class org.springframework.data.hadoop.store.support.InputContext
 
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.
setStopWaitResultsTimeout(long) - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
Sets the stop wait results timeout.
setStoreEventPublisher(StoreEventPublisher) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Sets the store event publisher.
setStrategies(List<? extends FileNamingStrategy>) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
Sets the list of strategies.
setStrategies(List<? extends RolloverStrategy>) - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
Sets the list of strategies.
setStream(T) - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
Sets the stream.
setSystemProcessExitCodeMapper(SystemProcessExitCodeMapper) - Method in class org.springframework.data.hadoop.batch.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
 
setTargetClass(Class<?>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
setTaskExecutor(TaskExecutor) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Sets the used TaskExecutor.
setTaskScheduler(TaskScheduler) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Sets the used TaskScheduler.
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.ToolExecutor
Sets the tool.
setToolClass(String) - Method in class org.springframework.data.hadoop.mapreduce.ToolExecutor
Sets the tool class by name.
setTrigger(Trigger) - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
Sets the trigger.
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.
setUuid(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
 
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.
setVerbose(boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Indicates whether the job execution is verbose (the default) or not.
setVerifyChecksum(boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
setWaitForCompletion(boolean) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Indicates whether the 'runner' should wait for the job to complete (default) after submission or not.
setWorkingDir(String) - Method in class org.springframework.data.hadoop.mapreduce.JobFactoryBean
Sets the job working directory.
setWorkingDirectory(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
setWrappedStream(T) - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
Sets the wrapped stream.
setWritePosition(long) - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy
 
setWritePosition(long) - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
 
setWritePosition(long) - Method in interface org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategy
Sets the write position.
setWritePosition(long) - Method in class org.springframework.data.hadoop.store.support.OutputContext
Sets the write position.
setWritePosition(long) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Sets the write position.
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).
shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.HiveRunnerParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.JarRunnerParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.ScriptParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.data.hadoop.config.ToolRunnerParser
 
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.
SizeRolloverStrategy - Class in org.springframework.data.hadoop.store.strategy.rollover
A RolloverStrategy using a size limiting a rollover operation.
SizeRolloverStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
Instantiates a new size rollover strategy.
SizeRolloverStrategy(long) - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
Instantiates a new size rollover strategy.
SizeRolloverStrategy(String) - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
Instantiates a new size rollover strategy.
SlopBlockSplitter - Class in org.springframework.data.hadoop.store.split
A SlopBlockSplitter is a Splitter which roughly splitting at least on block boundaries allowing last block to be combined with previous if its size is too small.
SlopBlockSplitter() - Constructor for class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Instantiates a new slop block splitter.
SlopBlockSplitter(Configuration) - Constructor for class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Instantiates a new slop block splitter.
SlopBlockSplitter(Configuration, long, long) - Constructor for class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Instantiates a new slop block splitter.
SlopBlockSplitter(Configuration, long, long, double) - Constructor for class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Instantiates a new slop block splitter.
Split - Interface in org.springframework.data.hadoop.store.split
Interface defining a split.
SplitLocation - Interface in org.springframework.data.hadoop.store.split
Interface representing a locations for Split.
Splitter - Interface in org.springframework.data.hadoop.store.split
A strategy interface for creating a list of Splits based on a Path representing a hdfs resource.
StandaloneHadoopCluster - Class in org.springframework.data.hadoop.test.support
Standalone simple mini cluster having MR and Hdfs nodes.
StandaloneHadoopCluster(String) - Constructor for class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster
Instantiates a mini cluster with default cluster node count.
StandaloneHadoopCluster(String, int) - Constructor for class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster
Instantiates a mini cluster with given cluster node count.
start() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
start() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
start() - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
Starts the poller.
start() - Method in interface org.springframework.data.hadoop.test.context.HadoopCluster
Starts the cluster.
start() - Method in class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster
 
startJobs() - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
 
startJobs(JobExecutor.JobListener) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
 
startLocalOutput(Path, Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
startLocalOutput(String, String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
 
StaticBlockSplitter - Class in org.springframework.data.hadoop.store.split
A StaticBlockSplitter is a Splitter handling splits as relative of block sizes allowing to furthern split blocks on a smaller chunks.
StaticBlockSplitter() - Constructor for class org.springframework.data.hadoop.store.split.StaticBlockSplitter
Instantiates a new static block splitter.
StaticBlockSplitter(Configuration) - Constructor for class org.springframework.data.hadoop.store.split.StaticBlockSplitter
Instantiates a new static block splitter.
StaticBlockSplitter(Configuration, int) - Constructor for class org.springframework.data.hadoop.store.split.StaticBlockSplitter
Instantiates a new static block splitter.
StaticFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
A FileNamingStrategy which simply uses a static file name.
StaticFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
Instantiates a new static file naming strategy.
StaticFileNamingStrategy(String) - Constructor for class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
Instantiates a new static file naming strategy.
StaticFileNamingStrategy(String, String) - Constructor for class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
 
StaticLengthSplitter - Class in org.springframework.data.hadoop.store.split
A StaticLengthSplitter is a Splitter using a static length to split a resource into an equal sized.
StaticLengthSplitter(long) - Constructor for class org.springframework.data.hadoop.store.split.StaticLengthSplitter
Instantiates a new static length splitter.
StaticLengthSplitter(Configuration, long) - Constructor for class org.springframework.data.hadoop.store.split.StaticLengthSplitter
Instantiates a new static length splitter.
stop() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
stop(Runnable) - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
 
stop() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
stop(Runnable) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
stop() - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
Stops the poller.
stop() - Method in interface org.springframework.data.hadoop.test.context.HadoopCluster
Stops the cluster.
stop() - Method in class org.springframework.data.hadoop.test.support.StandaloneHadoopCluster
 
stopCluster(Object) - Static method in class org.springframework.data.hadoop.test.support.compat.MiniMRClusterCompat
Finds and calls lifecycle stop method for given cluster via reflection.
stopJobs() - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Stops running job.
stopJobs(JobExecutor.JobListener) - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
Stops running job.
StoreContextUtils - Class in org.springframework.data.hadoop.store.support
Utility methods for accessing common components from the BeanFactory.
StoreContextUtils() - Constructor for class org.springframework.data.hadoop.store.support.StoreContextUtils
 
StoreEventPublisher - Interface in org.springframework.data.hadoop.store.event
Interface for publishing store based application events.
StoreException - Exception in org.springframework.data.hadoop.store
An exception that indicates there was an error accessing the the underlying HDFS store implementation.
StoreException(String, Throwable) - Constructor for exception org.springframework.data.hadoop.store.StoreException
Constructor for StoreException.
StoreException(String) - Constructor for exception org.springframework.data.hadoop.store.StoreException
Constructor for StoreException.
StoreObjectSupport - Class in org.springframework.data.hadoop.store.support
Base implementation of a store objects sharing a common functionality among store formats.
StoreObjectSupport(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.support.StoreObjectSupport
Instantiates a new abstract store support.
StoreSystemConstants - Class in org.springframework.data.hadoop.store
Various constants throughout the store package.
StoreSystemConstants() - Constructor for class org.springframework.data.hadoop.store.StoreSystemConstants
 
StoreUtils - Class in org.springframework.data.hadoop.store.support
Utility methods for store package.
StoreUtils() - Constructor for class org.springframework.data.hadoop.store.support.StoreUtils
 
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
 
StreamsHolder<T extends java.io.Closeable> - Class in org.springframework.data.hadoop.store.support
Holder object for streams.
StreamsHolder() - Constructor for class org.springframework.data.hadoop.store.support.StreamsHolder
Instantiates a new streams holder.
StreamsHolder(T, T) - Constructor for class org.springframework.data.hadoop.store.support.StreamsHolder
Instantiates a new streams holder.
StreamsHolder(T, T, Path) - Constructor for class org.springframework.data.hadoop.store.support.StreamsHolder
Instantiates a new streams holder.
stringPropertyNames() - Method in class org.springframework.data.hadoop.config.LinkedProperties
 
A B C D E F G H I J K L M N O P Q R S T U V W 
Spring for Apache Hadoop