- 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
-
- 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
-
- setDatasetRepositoryFactory(DatasetRepositoryFactory) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- setDefaultDatasetDefinition(DatasetDefinition) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- 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
-
- 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
-
- 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
-