- DataReader<T> - Interface in org.springframework.data.hadoop.store
-
A DataReader is an interface for reader implementation
able to read entities from a store.
- datasetDefinition - Variable in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
- DatasetDefinition - Class in org.springframework.data.hadoop.store.dataset
-
Class to define the options for a Dataset
- DatasetDefinition() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(boolean) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(boolean, String) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(Class<?>, boolean, String) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(Class<?>, PartitionStrategy) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetDefinition(Class<?>, String, PartitionStrategy) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- DatasetOperations - Interface in org.springframework.data.hadoop.store.dataset
-
Interface specifying a basic set of Dataset operations against a specific
DatasetRepository.
- DatasetRepositoryCallback - Interface in org.springframework.data.hadoop.store.dataset
-
Callback interface for code that operates on a DatasetRepository.
- datasetRepositoryFactory - Variable in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
- DatasetRepositoryFactory - Class in org.springframework.data.hadoop.store.dataset
-
Factory class responsible for creating DatasetRepository instances.
- DatasetRepositoryFactory() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
-
- DatasetTemplate - Class in org.springframework.data.hadoop.store.dataset
-
This is the central class in the store.dataset package.
- DatasetTemplate() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- DatasetTemplate(DatasetRepositoryFactory) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- DatasetTemplate(DatasetRepositoryFactory, DatasetDefinition) - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- DatasetUtils - Class in org.springframework.data.hadoop.store.dataset
-
This is a utility class in the store.dataset package.
- DatasetUtils() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetUtils
-
- DataStoreReader<T> - Interface in org.springframework.data.hadoop.store
-
A DataStoreReader is an extension of DataReader
adding methods from Closeable interface.
- DataStoreWriter<T> - Interface in org.springframework.data.hadoop.store
-
A DataStoreWriter is an extension of DataWriter
adding methods from Flushable and Closeable
interfaces.
- DataWriter<T> - Interface in org.springframework.data.hadoop.store
-
A DataWriter is an interface for writer implementation
able to write entities into a store.
- DateFormatMethodExecutor - Class in org.springframework.data.hadoop.store.expression
-
A MethodExecutor handling formatting using a SimpleDateFormat.
- DateFormatMethodExecutor() - Constructor for class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
Instantiates a new date format method executor.
- DateFormatMethodExecutor(String) - Constructor for class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
-
Instantiates a new date format method executor.
- decode(String) - Static method in class org.springframework.data.hadoop.util.ResourceUtils
-
Decodes the given encoded source String into an URI.
- DEFAULT_ID_CLUSTER - Static variable in class org.springframework.data.hadoop.test.HadoopTestSystemConstants
-
Default id for mini hadoop cluster.
- DEFAULT_ID_EVENT_PUBLISHER - Static variable in class org.springframework.data.hadoop.store.StoreSystemConstants
-
Default bean id for store event publisher.
- DEFAULT_ID_MINIHADOOPCLUSTER - Static variable in class org.springframework.data.hadoop.test.HadoopTestSystemConstants
-
Default bean id for mini hadoop cluster.
- DEFAULT_ID_MINIHADOOPCLUSTER_CONFIG - Static variable in class org.springframework.data.hadoop.test.HadoopTestSystemConstants
-
Default bean id for mini hadoop cluster configured configuration.
- DEFAULT_ID_RESOURCE_LOADER - Static variable in class org.springframework.data.hadoop.HadoopSystemConstants
-
- DEFAULT_ID_RESOURCE_LOADER_REGISTRAR - Static variable in class org.springframework.data.hadoop.HadoopSystemConstants
-
- DEFAULT_MAX_OPEN_ATTEMPTS - Static variable in class org.springframework.data.hadoop.store.output.AbstractDataStreamWriter
-
- DEFAULT_SPLIT_SLOP - Static variable in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
-
- DefaultCodecInfo - Class in org.springframework.data.hadoop.store.codec
-
A default CodecInfo implementation.
- DefaultCodecInfo(String, boolean, String) - Constructor for class org.springframework.data.hadoop.store.codec.DefaultCodecInfo
-
Instantiates a new default codec info.
- defaultId(ParserContext, Element) - Method in class org.springframework.data.hadoop.config.AbstractImprovedSimpleBeanDefinitionParser
-
- defaultId(ParserContext, Element) - Method in class org.springframework.data.hadoop.config.PigServerParser
-
- DefaultPartitionKey - Class in org.springframework.data.hadoop.store.partition
-
A default partition key which simply is a Map.
- DefaultPartitionKey() - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key.
- DefaultPartitionKey(long) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key using
a given timestamp.
- DefaultPartitionKey(long, Object) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key using
a given timestamp and a content object.
- DefaultPartitionKey(Object) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key using
a content object.
- DefaultPartitionKey(Map<? extends String, ? extends Object>) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
-
Instantiates a new default partition key
with a Map.
- DefaultPartitionStrategy<T> - Class in org.springframework.data.hadoop.store.partition
-
A
PartitionStrategy which is used to provide a generic partitioning support using Spring SpEL.
- DefaultPartitionStrategy(Expression) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy.
- DefaultPartitionStrategy(Expression, EvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy with
EvaluationContext.
- DefaultPartitionStrategy(String) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy.
- DefaultPartitionStrategy(String, EvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy with
EvaluationContext.
- DefaultPropertiesConfigurer<O,I,B extends AnnotationBuilder<O>> - Class in org.springframework.data.hadoop.config.common.annotation.configurers
-
- DefaultPropertiesConfigurer() - Constructor for class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultPropertiesConfigurer
-
- DefaultResourceConfigurer<O,I,B extends AnnotationBuilder<O>> - Class in org.springframework.data.hadoop.config.common.annotation.configurers
-
- DefaultResourceConfigurer() - Constructor for class org.springframework.data.hadoop.config.common.annotation.configurers.DefaultResourceConfigurer
-
- DefaultStoreEventPublisher - Class in org.springframework.data.hadoop.store.event
-
The default strategy for publishing store events.
- DefaultStoreEventPublisher() - Constructor for class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher
-
Constructs default strategy without an event publisher.
- DefaultStoreEventPublisher(ApplicationEventPublisher) - Constructor for class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher
-
Constructs default strategy with an event publisher.
- delete(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- delete(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- delete(Path, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- delete(String, boolean) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- deleteOnExit(Path) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- deleteOnExit(String) - Method in class org.springframework.data.hadoop.fs.SimplerFileSystem
-
- DelimitedTextFileReader - Class in org.springframework.data.hadoop.store.input
-
A DelimitedTextFileReader is a DataStoreReader implementation
able to read Strings from a raw hdfs files as delimited fields.
- DelimitedTextFileReader(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
Instantiates a new delimited text file reader.
- DelimitedTextFileReader(Configuration, Path, CodecInfo, byte[]) - Constructor for class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
Instantiates a new delimited text file reader.
- DelimitedTextFileReader(Configuration, Path, CodecInfo, Split, byte[], byte[]) - Constructor for class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
-
Instantiates a new delimited text file reader.
- DelimitedTextFileWriter - Class in org.springframework.data.hadoop.store.output
-
A DelimitedTextFileWriter is a DataStoreWriter implementation
able to write Strings into raw hdfs files as delimited fields.
- DelimitedTextFileWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
Instantiates a new delimited text file writer.
- DelimitedTextFileWriter(Configuration, Path, CodecInfo, byte[]) - Constructor for class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
Instantiates a new delimited text file writer.
- DelimitedTextFileWriter(Configuration, Path, CodecInfo, byte[], byte[]) - Constructor for class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
-
Instantiates a new delimited text file writer.
- destroy() - Method in class org.springframework.data.hadoop.fs.FileSystemFactoryBean
-
- destroy() - Method in class org.springframework.data.hadoop.fs.FsShell
-
- destroy() - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
- destroy() - Method in class org.springframework.data.hadoop.hbase.HbaseConfigurationFactoryBean
-
- destroy() - Method in class org.springframework.data.hadoop.hive.HiveServerFactoryBean
-
- destroy() - Method in class org.springframework.data.hadoop.mapreduce.JobExecutor
-
- destroy() - Method in class org.springframework.data.hadoop.test.support.HadoopClusterDelegatingFactoryBean
-
- destroy() - Method in class org.springframework.data.hadoop.test.support.HadoopClusterFactoryBean
-
- destroyWriter(Path) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Destroys a writer with a given Path if exist.
- determineRootDir(String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Determine the root directory for the given location.
- dispatch(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- DistCp - Class in org.springframework.data.hadoop.fs
-
Exposes the Hadoop command-line
distcp as an embeddable API.
- DistCp(Configuration) - Constructor for class org.springframework.data.hadoop.fs.DistCp
-
Constructs a new DistCp instance.
- DistCp(Configuration, String) - Constructor for class org.springframework.data.hadoop.fs.DistCp
-
- DistCp.Preserve - Enum in org.springframework.data.hadoop.fs
-
Enumeration for the possible attributes that can be preserved by a copy operation.
- DistributedCacheFactoryBean - Class in org.springframework.data.hadoop.fs
-
Factory for easy declarative configuration of a DistributedCache.
- DistributedCacheFactoryBean() - Constructor for class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean
-
- DistributedCacheFactoryBean.CacheEntry - Class in org.springframework.data.hadoop.fs
-
Class describing an entry of the distributed cache.
- DistributedCacheFactoryBean.CacheEntry(DistributedCacheFactoryBean.CacheEntry.EntryType, String) - Constructor for class org.springframework.data.hadoop.fs.DistributedCacheFactoryBean.CacheEntry
-
Constructs a new CacheEntry instance.
- DistributedCacheFactoryBean.CacheEntry.EntryType - Enum in org.springframework.data.hadoop.fs
-
A distributed cache entry type.
- doBuild() - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractAnnotationBuilder
-
Subclasses should implement this to perform the build.
- doBuild() - Method in class org.springframework.data.hadoop.config.common.annotation.AbstractConfiguredAnnotationBuilder
-
- doClose() - Method in class org.springframework.data.hadoop.test.support.HadoopClusterManager
-
Bring down and un-register all the running clusters.
- doDateFormat(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- doFindMatchingFileSystemResources(Path, String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Find all resources in the file system that match the given location pattern
via the Ant-style PathMatcher.
- doFindPathMatchingFileResources(Resource, String) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Find all resources in the hdfs file system that match the given location pattern
via the Ant-style PathMatcher.
- doHash(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- doHashList(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- doHashRange(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- doInHive(HiveClient) - Method in interface org.springframework.data.hadoop.hive.HiveClientCallback
-
- doInPig(PigServer) - Method in interface org.springframework.data.hadoop.pig.PigCallback
-
- doInRecord(T) - Method in interface org.springframework.data.hadoop.store.dataset.RecordCallback
-
- doInRepository(DatasetRepository) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetRepositoryCallback
-
- doInTable(HTableInterface) - Method in interface org.springframework.data.hadoop.hbase.TableCallback
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.AbstractGenericOptionsParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.AbstractImprovedSimpleBeanDefinitionParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.AbstractPropertiesConfiguredBeanDefinitionParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.HadoopResourceLoaderRegistrarParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.HiveRunnerParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.JarRunnerParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.PigServerParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.ScriptParser
-
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.data.hadoop.config.ToolRunnerParser
-
- doPath(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
-
- doPoll() - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
-
Do poll.
- doRead(T) - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
-
Do read.
- doRetrieveMatchingFiles(String, Path, Set<Path>) - Method in class org.springframework.data.hadoop.fs.HdfsResourceLoader
-
Recursively retrieve files that match the given pattern,
adding them to the given result list.
- doStart() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
- doStart() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
Subclasses may implement this method with the start behaviour.
- doStart() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
-
- doStop() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
- doStop() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
Subclasses may implement this method with the stop behaviour.
- doStop() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
-
- doWrite(List<? extends T>) - Method in class org.springframework.data.hadoop.batch.item.HdfsItemWriter
-
Performs the actual write to the store via the template.
- du(String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- du(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- du(boolean, String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- du(boolean, String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- dus(String) - Method in class org.springframework.data.hadoop.fs.FsShell
-
- dus(String...) - Method in class org.springframework.data.hadoop.fs.FsShell
-