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

A

AbstractDatasetStoreWriter<T> - Class in org.springframework.data.hadoop.store.dataset
An abstract DataStoreWriter to be extended for providing Dataset writing capabilities for specific use cases.
AbstractDatasetStoreWriter(Class<T>, DatasetRepositoryFactory, DatasetDefinition) - Constructor for class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
Instantiates a new DataStoreWriter for writing to a org.kitesdk.data.Dataset.
AbstractDataStreamReader - Class in org.springframework.data.hadoop.store.input
A AbstractDataStreamReader is a base implementation handling streams with a raw hdfs files.
AbstractDataStreamReader(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.input.AbstractDataStreamReader
Instantiates a new abstract data stream reader.
AbstractDataStreamReader(Configuration, Path, CodecInfo, Split) - Constructor for class org.springframework.data.hadoop.store.input.AbstractDataStreamReader
Instantiates a new abstract data stream reader.
AbstractDataStreamReader.ReaderHelper<T,V> - Class in org.springframework.data.hadoop.store.input
Reader helper hiding complexity of working with input streams.
AbstractDataStreamReader.ReaderHelper(StreamsHolder<InputStream>, InputContext, Split, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
Instantiates a new reader helper.
AbstractDataStreamWriter - Class in org.springframework.data.hadoop.store.output
A AbstractDataStreamWriter is a base implementation handling streams with a raw hdfs files.
AbstractDataStreamWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.AbstractDataStreamWriter
Instantiates a new abstract data stream writer.
AbstractFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
Base class for FileNamingStrategy implementations.
AbstractFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
 
AbstractPartitionDataStoreWriter<T,K> - Class in org.springframework.data.hadoop.store.output
Base implementation of PartitionDataStoreWriter.
AbstractPartitionDataStoreWriter(Configuration, Path, CodecInfo, PartitionStrategy<T, K>) - Constructor for class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Instantiates a new abstract data store partition writer.
AbstractPartitionStrategy<T,K> - Class in org.springframework.data.hadoop.store.partition
Base implementation of PartitionStrategy.
AbstractPartitionStrategy(PartitionResolver<K>, PartitionKeyResolver<T, K>) - Constructor for class org.springframework.data.hadoop.store.partition.AbstractPartitionStrategy
Instantiates a new abstract partition strategy.
AbstractRolloverStrategy - Class in org.springframework.data.hadoop.store.strategy.rollover
Base class for RolloverStrategy implementations.
AbstractRolloverStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy
 
AbstractSequenceFileReader - Class in org.springframework.data.hadoop.store.input
A AbstractSequenceFileReader is a base implementation handling reads with a SequenceFile.
AbstractSequenceFileReader(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.input.AbstractSequenceFileReader
Instantiates a new abstract sequence file reader.
AbstractSequenceFileWriter - Class in org.springframework.data.hadoop.store.output
A AbstractSequenceFileWriter is a base implementation handling writes with a SequenceFile.
AbstractSequenceFileWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.AbstractSequenceFileWriter
Instantiates a new abstract sequence file writer.
AbstractSplitter - Class in org.springframework.data.hadoop.store.split
A base class for Splitter implementations.
AbstractSplitter() - Constructor for class org.springframework.data.hadoop.store.split.AbstractSplitter
Instantiates a new abstract splitter.
AbstractSplitter(Configuration) - Constructor for class org.springframework.data.hadoop.store.split.AbstractSplitter
Instantiates a new abstract splitter.
AbstractStoreEvent - Class in org.springframework.data.hadoop.store.event
Base ApplicationEvent class for store based events.
AbstractStoreEvent(Object) - Constructor for class org.springframework.data.hadoop.store.event.AbstractStoreEvent
Create a new ApplicationEvent.
add(S) - Method in class org.springframework.data.hadoop.store.support.OrderedComposite
Register additional item.
afterPropertiesSet() - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
AvroPojoDatasetStoreWriter<T> - Class in org.springframework.data.hadoop.store.dataset
A DataStoreWriter for writing Datasets using the Avro format.
AvroPojoDatasetStoreWriter(Class<T>, DatasetRepositoryFactory) - Constructor for class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
Instantiates a new DataStoreWriter for writing Avro records to a org.kitesdk.data.Dataset.
AvroPojoDatasetStoreWriter(Class<T>, DatasetRepositoryFactory, DatasetDefinition) - Constructor for class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
Instantiates a new DataStoreWriter for writing Avro records to a org.kitesdk.data.Dataset.

B

BUFFER_SIZE - Static variable in class org.springframework.data.hadoop.store.support.StoreUtils
 
buildSplit(long, long, String[]) - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
Builds the split.

C

ChainedFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
A FileNamingStrategy chaining other strategies.
ChainedFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
Instantiates a new chained rollover strategy.
ChainedFileNamingStrategy(List<? extends FileNamingStrategy>) - Constructor for class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
Instantiates a new chained rollover strategy.
ChainedRolloverStrategy - Class in org.springframework.data.hadoop.store.strategy.rollover
RolloverStrategy which is simply chaining other strategies.
ChainedRolloverStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
Instantiates a new chained rollover strategy.
ChainedRolloverStrategy(List<? extends RolloverStrategy>) - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
Instantiates a new chained rollover strategy.
close() - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
 
close() - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
 
close() - Method in class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
 
close() - Method in class org.springframework.data.hadoop.store.input.TextFileReader
 
close() - Method in class org.springframework.data.hadoop.store.input.TextSequenceFileReader
 
close() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
 
close() - Method in class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
 
close() - Method in class org.springframework.data.hadoop.store.output.OutputStreamWriter
 
close() - Method in class org.springframework.data.hadoop.store.output.TextFileWriter
 
close() - Method in class org.springframework.data.hadoop.store.output.TextSequenceFileWriter
 
close() - Method in class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder
 
close() - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
Close both streams in this holder.
CodecFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
A FileNamingStrategy which adds suffix based on known codec.
CodecFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
Instantiates a new codec file naming strategy.
CodecInfo - Interface in org.springframework.data.hadoop.store.codec
Generic interface for supported codec info.
Codecs - Enum in org.springframework.data.hadoop.store.codec
Default codecs supported by store framework.
computeSplitSize(long, long, long) - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
Compute split size.
computeSplitSize(long, long, long) - Method in class org.springframework.data.hadoop.store.split.StaticBlockSplitter
 
copy(InputStream, DataStoreWriter<byte[]>) - Static method in class org.springframework.data.hadoop.store.support.StoreUtils
Copy the contents of the given InputStream to the given DataStoreWriter.
copyStream(InputStream, DataStoreWriter<byte[]>) - Static method in class org.springframework.data.hadoop.store.support.StoreUtils
Copy the contents of the given InputStream to the given DataStoreWriter.
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
 
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
 
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
 
createInstance() - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategyFactory
Creates a new instance of FileNamingStrategy.
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
 
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
 
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
 
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy
 
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
 
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.NoRolloverStrategy
 
createInstance() - Method in interface org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategyFactory
Creates a new instance of RolloverStrategy.
createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
 
createReader(InputStream) - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
Creates the reader.
createWriter(Configuration, Path, CodecInfo) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Need to be implemented by a subclass for an actual writer.
createWriter(Configuration, Path, CodecInfo) - Method in class org.springframework.data.hadoop.store.output.PartitionTextFileWriter
 
CSV - Static variable in class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
CSV Mode
CSV - Static variable in class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
CSV Mode

D

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.
dateFormat(String, Integer) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
 
dateFormat(String, Long) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
 
dateFormat(String, Date) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
 
dateFormat(String, String) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
 
dateFormat(String, String, String) - Static method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
 
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.
DEFAULT_ID_EVENT_PUBLISHER - Static variable in class org.springframework.data.hadoop.store.StoreSystemConstants
Default bean id for store event publisher.
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.
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.
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.
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.
destroyWriter(Path) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Destroys a writer with a given Path if exist.
doInRecord(T) - Method in interface org.springframework.data.hadoop.store.dataset.RecordCallback
 
doInRepository(DatasetRepository) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetRepositoryCallback
 
doInView(Dataset<T>, Class<T>) - Method in interface org.springframework.data.hadoop.store.dataset.ViewCallback
 
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.
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
 

E

entityClass - Variable in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
 
equals(Object) - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
equals(Object) - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
 
execute(DatasetRepositoryCallback) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Execute a callback for the DatasetRepository
execute(DatasetRepositoryCallback) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
execute(EvaluationContext, Object, Object...) - Method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
 
execute(EvaluationContext, Object, Object...) - Method in class org.springframework.data.hadoop.store.expression.HashListMethodExecutor
 
execute(EvaluationContext, Object, Object...) - Method in class org.springframework.data.hadoop.store.expression.HashMethodExecutor
 
execute(EvaluationContext, Object, Object...) - Method in class org.springframework.data.hadoop.store.expression.HashRangeMethodExecutor
 
execute(EvaluationContext, Object, Object...) - Method in class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 

F

FileNamingStrategy - Interface in org.springframework.data.hadoop.store.strategy.naming
Strategy interface for components naming files.
FileNamingStrategyFactory<T extends FileNamingStrategy> - Interface in org.springframework.data.hadoop.store.strategy.naming
Factory interface creating instances of FileNamingStrategys.
FileWrittenEvent - Class in org.springframework.data.hadoop.store.event
Generic event representing that Path has been written.
FileWrittenEvent(Object, Path) - Constructor for class org.springframework.data.hadoop.store.event.FileWrittenEvent
Instantiates a new file written event.
findInitFiles(Path) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
 
flush() - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
 
flush() - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
 
flush() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
 
flush() - Method in class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
 
flush() - Method in class org.springframework.data.hadoop.store.output.OutputStreamWriter
 
flush() - Method in class org.springframework.data.hadoop.store.output.TextFileWriter
 
flush() - Method in class org.springframework.data.hadoop.store.output.TextSequenceFileWriter
 

G

GenericSplit - Class in org.springframework.data.hadoop.store.split
A GenericSplit is simple implementation of Split and SplitLocation storing needed information as it is.
GenericSplit() - Constructor for class org.springframework.data.hadoop.store.split.GenericSplit
Instantiates a new generic split.
GenericSplit(long, long, String[]) - Constructor for class org.springframework.data.hadoop.store.split.GenericSplit
Instantiates a new generic split.
get(String) - Static method in enum org.springframework.data.hadoop.store.codec.Codecs
Gets the Codecs by its abbreviation.
getAbbreviation() - Method in enum org.springframework.data.hadoop.store.codec.Codecs
Gets the main abbreviation.
getAbbreviations() - Method in enum org.springframework.data.hadoop.store.codec.Codecs
Gets the abbreviations.
getBasePath() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the base path.
getBeanFactory() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Gets the BeanFactory for this instance.
getBlockIndex(BlockLocation[], long) - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
Gets the block index.
getCodec() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the codec.
getCodec() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
Gets the codec.
getCodecClass() - Method in interface org.springframework.data.hadoop.store.codec.CodecInfo
Gets the fully qualified name of a codec class.
getCodecClass() - Method in class org.springframework.data.hadoop.store.codec.DefaultCodecInfo
 
getCodecInfo() - Method in enum org.springframework.data.hadoop.store.codec.Codecs
Gets the codec info.
getCodecInfo(String) - Static method in enum org.springframework.data.hadoop.store.codec.Codecs
Gets the CodecInfo by Codecs abbreviation.
getCodecInfo() - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
Gets the codec info.
getConfiguration() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the hadoop configuration.
getConfiguration() - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
Gets the hadoop configuration.
getConfiguration() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
Gets the configuration.
getContext() - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
Gets the wrapped InputContext.
getDataset(DatasetRepositoryFactory, Class<T>) - Static method in class org.springframework.data.hadoop.store.dataset.DatasetUtils
 
getDatasetDefinitions() - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
The DatasetDefinitions used for this template.
getDatasetDescriptor(Class<T>) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Get the DatasetDescriptor for the given class
getDatasetDescriptor(Class<T>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
getDatasetName(Class<T>) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Get the dataset name to be used for the given class
getDatasetName(Class<T>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
getDatasetName(Class<T>) - Static method in class org.springframework.data.hadoop.store.dataset.DatasetUtils
 
getDatasetRepository() - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
Get the DatasetRepository
getDefaultDatasetDefinition() - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
The default DatasetDefinition used for this template.
getDefaultSuffix() - Method in interface org.springframework.data.hadoop.store.codec.CodecInfo
Gets the default suffix.
getDefaultSuffix() - Method in class org.springframework.data.hadoop.store.codec.DefaultCodecInfo
 
getEnd() - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
getEnd() - Method in interface org.springframework.data.hadoop.store.split.Split
Gets the split end position.
getEnd() - Method in class org.springframework.data.hadoop.store.support.InputContext
 
getEventPublisher(BeanFactory) - Static method in class org.springframework.data.hadoop.store.support.StoreContextUtils
Return the StoreEventPublisher bean whose name is "storeEventPublisher" if available.
getFileNamingStrategyFactory() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the file naming strategy factory.
getFormat() - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
getHolder() - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
Gets the StreamsHolder for wrapped input stream.
getIdleTimeout() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the idle timeout.
getInput() - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader
Creates a holder wrapping input stream.
getInput() - Method in class org.springframework.data.hadoop.store.input.AbstractSequenceFileReader
 
getInputContext() - Method in class org.springframework.data.hadoop.store.support.InputStoreObjectSupport
Gets the input context.
getInWritingPrefix() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the in writing prefix.
getInWritingSuffix() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the in writing suffix.
getItems() - Method in class org.springframework.data.hadoop.store.support.OrderedComposite
Public getter for the items.
getKey() - Method in class org.springframework.data.hadoop.store.expression.DateFormatMethodExecutor
Gets the key for timestamp if defined.
getLength() - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
getLength() - Method in interface org.springframework.data.hadoop.store.split.Split
Gets the split length.
getLocations() - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
getLocations() - Method in interface org.springframework.data.hadoop.store.split.SplitLocation
Gets the locations of a split.
getMaxOpenAttempts() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the max open attempts.
getMaxSplitSize() - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Gets the maximum split size.
getMinSplitSize() - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Gets the minimum split size.
getNamespace() - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
Get the namespace to use.
getOrCreateDataset(DatasetRepositoryFactory, DatasetDefinition, Class<?>, Class<T>) - Static method in class org.springframework.data.hadoop.store.dataset.DatasetUtils
 
getOrder() - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
Implementation should override this method to define a chaining order.
getOrder() - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
 
getOrder() - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy
Implementation should override this method to define a chaining order.
getOutput() - Method in class org.springframework.data.hadoop.store.output.AbstractDataStreamWriter
Gets the output.
getOutput() - Method in class org.springframework.data.hadoop.store.output.AbstractSequenceFileWriter
Gets the output.
getOutputContext() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Gets the strategy context.
getPartitionKeyResolver() - Method in class org.springframework.data.hadoop.store.partition.AbstractPartitionStrategy
 
getPartitionKeyResolver() - Method in interface org.springframework.data.hadoop.store.partition.PartitionStrategy
Gets the partition key resolver.
getPartitionResolver() - Method in class org.springframework.data.hadoop.store.partition.AbstractPartitionStrategy
 
getPartitionResolver() - Method in interface org.springframework.data.hadoop.store.partition.PartitionStrategy
Gets the partition resolver.
getPartitionStrategy() - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
getPath() - Method in class org.springframework.data.hadoop.store.event.FileWrittenEvent
Gets the path.
getPath() - Method in class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder
Gets the path.
getPath() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
Gets the path.
getPath() - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
Gets the path.
getPhase() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
getPosition(StreamsHolder<OutputStream>) - Method in class org.springframework.data.hadoop.store.output.AbstractDataStreamWriter
Gets the current stream writing position.
getPosition(SequenceFile.Writer) - Method in class org.springframework.data.hadoop.store.output.AbstractSequenceFileWriter
 
getPosition() - Method in class org.springframework.data.hadoop.store.strategy.rollover.AbstractRolloverStrategy
 
getPosition() - Method in class org.springframework.data.hadoop.store.support.InputContext
 
getReader() - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
getResolvedPath() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Gets the resolved path.
getRolloverState() - Method in class org.springframework.data.hadoop.store.support.OutputContext
Gets the rollover state.
getRolloverStrategyFactory() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Gets the rollover strategy factory.
getSchema(Class<?>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
getSplit() - Method in class org.springframework.data.hadoop.store.support.InputStoreObjectSupport
Gets the input split.
getSplits(Path) - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
 
getSplits(Path) - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
 
getSplits(Path) - Method in interface org.springframework.data.hadoop.store.split.Splitter
Gets the input splits for a Path.
getStart() - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
getStart() - Method in interface org.springframework.data.hadoop.store.split.Split
Gets the split start position.
getStart() - Method in class org.springframework.data.hadoop.store.support.InputContext
 
getStoreEventPublisher() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Gets the store event publisher.
getStrategies() - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
Gets the strategies.
getStrategies() - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
Gets the strategies.
getStream() - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
Gets the stream.
getTargetClass() - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
getTaskExecutor() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Gets the defined TaskExecutor.
getTaskExecutor(BeanFactory) - Static method in class org.springframework.data.hadoop.store.support.StoreContextUtils
Return the TaskScheduler bean whose name is "taskExecutor" if available.
getTaskScheduler() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Gets the defined TaskScheduler.
getTaskScheduler(BeanFactory) - Static method in class org.springframework.data.hadoop.store.support.StoreContextUtils
Return the TaskScheduler bean whose name is "taskScheduler" if available.
getUTF8CsvDelimiter() - Static method in class org.springframework.data.hadoop.store.support.StoreUtils
Gets the default utf8 csv delimiter.
getUTF8DefaultDelimiter() - Static method in class org.springframework.data.hadoop.store.support.StoreUtils
Gets the default utf8 delimiter.
getUTF8TabDelimiter() - Static method in class org.springframework.data.hadoop.store.support.StoreUtils
Gets the default utf8 tab delimiter.
getUuid() - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
 
getValue(Expression, Map<String, Object>, Class<T>) - Method in class org.springframework.data.hadoop.store.expression.MapExpressionMethods
Gets the value.
getWrappedStream() - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
Gets the wrapped stream.
getWriter() - Method in class org.springframework.data.hadoop.store.support.SequenceFileWriterHolder
Gets the writer.
getWriterCacheSize() - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 

H

handleIdleTimeout() - Method in class org.springframework.data.hadoop.store.output.OutputStreamWriter
 
handleIdleTimeout() - Method in class org.springframework.data.hadoop.store.output.TextFileWriter
 
handleIdleTimeout() - Method in class org.springframework.data.hadoop.store.output.TextSequenceFileWriter
 
handleIdleTimeout() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
Handle idle timeout.
hash(int, int) - Static method in class org.springframework.data.hadoop.store.expression.HashMethodExecutor
 
hash(Object, Integer) - Static method in class org.springframework.data.hadoop.store.expression.HashMethodExecutor
 
hashCode() - Method in class org.springframework.data.hadoop.store.split.GenericSplit
 
hashCode() - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
 
HashListMethodExecutor - Class in org.springframework.data.hadoop.store.expression
A MethodExecutor using an first argument as key to be matched from second argument which is expected to be a List of List of Objects.
HashListMethodExecutor() - Constructor for class org.springframework.data.hadoop.store.expression.HashListMethodExecutor
 
HashMethodExecutor - Class in org.springframework.data.hadoop.store.expression
A MethodExecutor using an first argument as an Object to get its hashcode and second argument expected to be an Integer to calculate a simple bucket name.
HashMethodExecutor() - Constructor for class org.springframework.data.hadoop.store.expression.HashMethodExecutor
 
HashRangeMethodExecutor - Class in org.springframework.data.hadoop.store.expression
A MethodExecutor using an first argument as key to be used as a range search with a List of Object found from a second argument.
HashRangeMethodExecutor() - Constructor for class org.springframework.data.hadoop.store.expression.HashRangeMethodExecutor
 
hasRolled() - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
 
hasRolled() - Method in class org.springframework.data.hadoop.store.strategy.rollover.NoRolloverStrategy
 
hasRolled() - Method in interface org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategy
Checks if strategy wants to rollover.
hasRolled() - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
 
hflush() - Method in class org.springframework.data.hadoop.store.output.OutputStreamWriter
 
hflush() - Method in class org.springframework.data.hadoop.store.output.TextSequenceFileWriter
 

I

IdleTimeoutTrigger - Class in org.springframework.data.hadoop.store.support
A Trigger for idle timeout task execution.
IdleTimeoutTrigger(long) - Constructor for class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
Instantiates a new idle timeout trigger.
IdleTimeoutTrigger(long, TimeUnit) - Constructor for class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
Instantiates a new idle timeout trigger.
init() - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
Inits the reader helper.
init(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
 
init(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
 
init(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
 
init(Path) - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy
Initialises a starting state of a strategy.
init(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
 
init(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
 
init(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
 
init(Path) - Method in class org.springframework.data.hadoop.store.support.OutputContext
Inits the context from a Path
init() - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
Inits the poller.
initOutputContext() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
 
InputContext - Class in org.springframework.data.hadoop.store.support
Context keeping information about a current reading operation.
InputContext(long, long) - Constructor for class org.springframework.data.hadoop.store.support.InputContext
 
InputStoreObjectSupport - Class in org.springframework.data.hadoop.store.support
Base class for input readers sharing common functionality for Split and InputContext.
InputStoreObjectSupport(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.support.InputStoreObjectSupport
Instantiates a new input store object support.
InputStoreObjectSupport(Configuration, Path, CodecInfo, Split) - Constructor for class org.springframework.data.hadoop.store.support.InputStoreObjectSupport
Instantiates a new input store object support.
isAllowNullValues() - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
isAppendable() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Checks if append is enabled.
isAppendable() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Checks if file is appendable
isAutoStartup() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
isCompressed() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
Checks if is compressed.
isEnabled() - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
Checks if strategy is enabled.
isEndReached() - Method in class org.springframework.data.hadoop.store.support.InputContext
 
isFileWriteable(Path) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
 
isOverwrite() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Checks if overwrite is enabled.
isOverwrite() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Checks if overwrite is enabled.
isRunning() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
isSplittable() - Method in interface org.springframework.data.hadoop.store.codec.CodecInfo
Checks if codec is splittable.
isSplittable() - Method in class org.springframework.data.hadoop.store.codec.DefaultCodecInfo
 
iterator() - Method in class org.springframework.data.hadoop.store.support.OrderedComposite
Public getter for the list of items.

K

KEY_CONTENT - Static variable in class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
 
KEY_TIMESTAMP - Static variable in class org.springframework.data.hadoop.store.partition.DefaultPartitionKey
 

L

LifecycleObjectSupport - Class in org.springframework.data.hadoop.store.support
Convenient base class for object which needs spring task scheduler, task executor and life cycle handling.
LifecycleObjectSupport() - Constructor for class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
list(String, List<Object>) - Static method in class org.springframework.data.hadoop.store.expression.HashListMethodExecutor
 
LoggingListener - Class in org.springframework.data.hadoop.store.event
Simple ApplicationListener which logs all events based on AbstractStoreEvent using a log level set during the construction.
LoggingListener() - Constructor for class org.springframework.data.hadoop.store.event.LoggingListener
Constructs Logger listener with debug level.
LoggingListener(String) - Constructor for class org.springframework.data.hadoop.store.event.LoggingListener
Constructs Logger listener with given level.

M

MapExpressionMethods - Class in org.springframework.data.hadoop.store.expression
Helper class to work with a spel expressions resolving values from a Map.
MapExpressionMethods() - Constructor for class org.springframework.data.hadoop.store.expression.MapExpressionMethods
Instantiates a new map expression methods.
MapExpressionMethods(EvaluationContext) - Constructor for class org.springframework.data.hadoop.store.expression.MapExpressionMethods
Instantiates a new map expression methods with a EvaluationContext which is expected to be a StandardEvaluationContext.
METHOD_DATEFORMAT - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 
METHOD_HASH - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 
METHOD_HASHLIST - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 
METHOD_HASHRANGE - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 
METHOD_PATH - Static variable in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 

N

next() - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
 
next() - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
 
next() - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy
This method should be called to prepare next filename in case strategy doesn't know how to do it automatically.
next() - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
 
next() - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
 
next() - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
 
nextExecutionTime(TriggerContext) - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
 
NoRolloverStrategy - Class in org.springframework.data.hadoop.store.strategy.rollover
A RolloverStrategy which simply never does a rollover.
NoRolloverStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.rollover.NoRolloverStrategy
 

O

onApplicationEvent(AbstractStoreEvent) - Method in class org.springframework.data.hadoop.store.event.LoggingListener
 
onInit() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
 
onInit() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Subclasses may implement this for initialization logic.
onInit() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
 
onInit() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
 
onPollResult(T) - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
Callback on poll result.
OrderedComposite<S> - Class in org.springframework.data.hadoop.store.support
Composite item which can be used in other components which may want to allow automatic and annotation based ordering.
OrderedComposite() - Constructor for class org.springframework.data.hadoop.store.support.OrderedComposite
 
org.springframework.data.hadoop.store - package org.springframework.data.hadoop.store
 
org.springframework.data.hadoop.store.codec - package org.springframework.data.hadoop.store.codec
 
org.springframework.data.hadoop.store.dataset - package org.springframework.data.hadoop.store.dataset
 
org.springframework.data.hadoop.store.event - package org.springframework.data.hadoop.store.event
 
org.springframework.data.hadoop.store.expression - package org.springframework.data.hadoop.store.expression
 
org.springframework.data.hadoop.store.input - package org.springframework.data.hadoop.store.input
 
org.springframework.data.hadoop.store.output - package org.springframework.data.hadoop.store.output
 
org.springframework.data.hadoop.store.partition - package org.springframework.data.hadoop.store.partition
 
org.springframework.data.hadoop.store.split - package org.springframework.data.hadoop.store.split
 
org.springframework.data.hadoop.store.strategy.naming - package org.springframework.data.hadoop.store.strategy.naming
 
org.springframework.data.hadoop.store.strategy.rollover - package org.springframework.data.hadoop.store.strategy.rollover
 
org.springframework.data.hadoop.store.support - package org.springframework.data.hadoop.store.support
 
OutputContext - Class in org.springframework.data.hadoop.store.support
Context strategy keeping output state.
OutputContext() - Constructor for class org.springframework.data.hadoop.store.support.OutputContext
Instantiates a new strategy context.
OutputStoreObjectSupport - Class in org.springframework.data.hadoop.store.support
A OutputStoreObjectSupport is meant to be used from a store DataWriter implementations by keeping current writing state.
OutputStoreObjectSupport(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Instantiates a new abstract output store support.
OutputStreamWriter - Class in org.springframework.data.hadoop.store.output
A OutputStreamWriter is a DataStoreWriter implementation able to write byte[]s into raw hdfs files.
OutputStreamWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.OutputStreamWriter
Instantiates a new output stream writer.

P

ParquetDatasetStoreWriter<T> - Class in org.springframework.data.hadoop.store.dataset
A DataStoreWriter for writing Datasets using the Parquet format.
ParquetDatasetStoreWriter(Class<T>, DatasetRepositoryFactory) - Constructor for class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
Instantiates a new DataStoreWriter for writing Parquet records to a org.kitesdk.data.Dataset.
ParquetDatasetStoreWriter(Class<T>, DatasetRepositoryFactory, DatasetDefinition) - Constructor for class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
Instantiates a new DataStoreWriter for writing Parquet records to a org.kitesdk.data.Dataset.
PartitionDataStoreWriter<T,K> - Interface in org.springframework.data.hadoop.store
A DataStorePartitionWriter is an extension of DataStoreWriter adding functionality to write entities using a partition key.
PartitionKeyMethodResolver - Class in org.springframework.data.hadoop.store.expression
A MethodResolver handling custom methods internally without a need to register via variables.
PartitionKeyMethodResolver() - Constructor for class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 
PartitionKeyMethodResolver(boolean) - Constructor for class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 
PartitionKeyResolver<T,K> - Interface in org.springframework.data.hadoop.store.partition
A PartitionKeyResolver is a strategy interface defining entity is automatically translated into a matching partition key.
PartitionResolver<K> - Interface in org.springframework.data.hadoop.store.partition
A PartitionResolver is a strategy interface defining how partition key can be resolved into the actual Path.
PartitionStrategy<T,K> - Interface in org.springframework.data.hadoop.store.partition
A PartitionStrategy is a strategy interface defining used PartitionResolver and PartitionKeyResolver.
PartitionTextFileWriter<K> - Class in org.springframework.data.hadoop.store.output
Implementation of a PartitionDataStoreWriter writing text data using a partitioning.
PartitionTextFileWriter(Configuration, Path, CodecInfo, PartitionStrategy<String, K>) - Constructor for class org.springframework.data.hadoop.store.output.PartitionTextFileWriter
Instantiates a new text file partitioned writer.
path(String) - Static method in class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 
path(String...) - Static method in class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 
path(Long) - Static method in class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 
path(Long...) - Static method in class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 
path(Object) - Static method in class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 
path(Object...) - Static method in class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 
PathCombiningMethodExecutor - Class in org.springframework.data.hadoop.store.expression
A MethodExecutor making it easier to combine paths instead of concatenating in spel itself.
PathCombiningMethodExecutor() - Constructor for class org.springframework.data.hadoop.store.expression.PathCombiningMethodExecutor
 
PollingTaskSupport<T> - Class in org.springframework.data.hadoop.store.support
Helper class to ease working with polling tasks executed using Spring TaskScheduler and TaskExecutor.
PollingTaskSupport(TaskScheduler, TaskExecutor) - Constructor for class org.springframework.data.hadoop.store.support.PollingTaskSupport
Instantiates a new polling task support.
PollingTaskSupport(TaskScheduler, TaskExecutor, TimeUnit, long) - Constructor for class org.springframework.data.hadoop.store.support.PollingTaskSupport
Instantiates a new polling task support.
PollingTaskSupport(TaskScheduler, TaskExecutor, Trigger) - Constructor for class org.springframework.data.hadoop.store.support.PollingTaskSupport
Instantiates a new polling task support.
processReadCount(int) - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
Processing a count of bytes read from a stream.
publishEvent(AbstractStoreEvent) - Method in class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher
 
publishEvent(AbstractStoreEvent) - Method in interface org.springframework.data.hadoop.store.event.StoreEventPublisher
Publish a general application event of type AbstractStoreEvent.

R

range(Object, List<?>) - Static method in class org.springframework.data.hadoop.store.expression.HashRangeMethodExecutor
 
read() - Method in interface org.springframework.data.hadoop.store.DataReader
Read next entity from a reader.
read(Class<T>, RecordCallback<T>) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Read all records in the dataset and call the provided callback for each record.
read(Class<T>) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Read all records in the dataset and return as a collection.
read(Class<T>, RecordCallback<T>, ViewCallback) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Read records in the dataset partition based on a RefinableView and call the provided callback for each record.
read(Class<T>, ViewCallback) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Read records in the dataset partition based on the RefinableView and return as a collection.
read(Class<T>, RecordCallback<T>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
read(Class<T>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
read(Class<T>, RecordCallback<T>, ViewCallback) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
read(Class<T>, ViewCallback) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
read() - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
Reads a data by delegating to a reader.
read() - Method in class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
 
read() - Method in class org.springframework.data.hadoop.store.input.TextFileReader
 
read() - Method in class org.springframework.data.hadoop.store.input.TextSequenceFileReader
 
RecordCallback<T> - Interface in org.springframework.data.hadoop.store.dataset
Callback interface for code that operates on a Dataset record.
register(FileNamingStrategy) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
Register a new strategy.
register(RolloverStrategy) - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
Register a new strategy.
renameFile(Path) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Rename file using prefix and suffix settings.
reset() - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
 
reset() - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
 
reset() - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy
Resets the strategy to its original state.
reset() - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
 
reset() - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
 
reset() - Method in class org.springframework.data.hadoop.store.strategy.rollover.NoRolloverStrategy
 
reset() - Method in interface org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategy
Reset the strategy state.
reset() - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
 
reset() - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
Notify trigger that we should get into new timeout period.
resetIdleTimeout() - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
Reset idle timeout.
resolve(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.data.hadoop.store.expression.PartitionKeyMethodResolver
 
resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
 
resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.CodecFileNamingStrategy
 
resolve(Path) - Method in interface org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy
Resolve a current file path denoted by this strategy.
resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
 
resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
 
resolve(Path) - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
 
resolvePartitionKey(T) - Method in interface org.springframework.data.hadoop.store.partition.PartitionKeyResolver
Resolve partition key for a given entity.
resolvePath(K) - Method in interface org.springframework.data.hadoop.store.partition.PartitionResolver
Resolve path with a given partition key.
resolvePath(Path) - Method in class org.springframework.data.hadoop.store.support.OutputContext
Resolve path.
reverse() - Method in class org.springframework.data.hadoop.store.support.OrderedComposite
Public getter for the list of items in reverse.
RollingFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
A FileNamingStrategy which simply uses a rolling counter to give unique file name.
RollingFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
 
RolloverStrategy - Interface in org.springframework.data.hadoop.store.strategy.rollover
A strategy interface used for file or stream writers to determine when a file or a stream should be rolled over.
RolloverStrategyFactory<T extends RolloverStrategy> - Interface in org.springframework.data.hadoop.store.strategy.rollover
Factory interface creating instances of RolloverStrategys.
rollStrategies() - Method in class org.springframework.data.hadoop.store.support.OutputContext
Roll strategies.

S

schema - Variable in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
 
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
 
setAppendable(boolean) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
Set stream as append mode.
setAppendable(boolean) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
Set stream as append mode.
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.data.hadoop.store.event.DefaultStoreEventPublisher
 
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.
setBeanFactory(BeanFactory) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
 
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.
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.store.split.AbstractSplitter
Sets the configuration.
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.
setEnabled(boolean) - Method in class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy
Sets if this strategy is enabled.
setEnd(long) - Method in class org.springframework.data.hadoop.store.support.InputContext
 
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.
setFormat(String) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
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.
setInitialDelay(long) - Method in class org.springframework.data.hadoop.store.support.IdleTimeoutTrigger
Specify the delay for the initial execution.
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.
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.
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.
setMinSplitSize(long) - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Sets the minimum split size.
setName(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.StaticFileNamingStrategy
Sets the file name part.
setNamespace(String) - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
Namespace to use.
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.
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.
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.
setPhase(int) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
Sets the phase.
setPosition(long) - Method in class org.springframework.data.hadoop.store.support.InputContext
 
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.
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.
setSlop(double) - Method in class org.springframework.data.hadoop.store.split.SlopBlockSplitter
Sets the slop factor.
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
 
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.
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.
setTrigger(Trigger) - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
Sets the trigger.
setUuid(String) - Method in class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
 
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.
setWriterCacheSize(Integer) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
 
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.
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.
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.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.
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
 
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.

T

TAB - Static variable in class org.springframework.data.hadoop.store.input.DelimitedTextFileReader
TAB Mode
TAB - Static variable in class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
TAB Mode
TASK_EXECUTOR_BEAN_NAME - Static variable in class org.springframework.data.hadoop.store.support.StoreContextUtils
Default task executor bean name
TASK_SCHEDULER_BEAN_NAME - Static variable in class org.springframework.data.hadoop.store.support.StoreContextUtils
Default task scheduler bean name
TextFileReader - Class in org.springframework.data.hadoop.store.input
A TextFileReader is a DataStoreReader implementation able to read Strings from a raw hdfs files.
TextFileReader(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.input.TextFileReader
Instantiates a new text file reader.
TextFileReader(Configuration, Path, CodecInfo, Split) - Constructor for class org.springframework.data.hadoop.store.input.TextFileReader
Instantiates a new text file reader.
TextFileReader(Configuration, Path, CodecInfo, Split, byte[]) - Constructor for class org.springframework.data.hadoop.store.input.TextFileReader
Instantiates a new text file reader.
TextFileWriter - Class in org.springframework.data.hadoop.store.output
A TextFileWriter is a DataStoreWriter implementation able to write Strings into raw hdfs files.
TextFileWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.TextFileWriter
Instantiates a new text file writer.
TextFileWriter(Configuration, Path, CodecInfo, byte[]) - Constructor for class org.springframework.data.hadoop.store.output.TextFileWriter
Instantiates a new text file writer.
TextFileWriter(Configuration, Path, CodecInfo, byte[], long) - Constructor for class org.springframework.data.hadoop.store.output.TextFileWriter
Instantiates a new text file writer.
TextSequenceFileReader - Class in org.springframework.data.hadoop.store.input
A TextSequenceFileReader is a DataStoreReader implementation able to read Strings from a SequenceFile.
TextSequenceFileReader(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.input.TextSequenceFileReader
Instantiates a new text sequence file reader.
TextSequenceFileWriter - Class in org.springframework.data.hadoop.store.output
A TextSequenceFileWriter is a DataStoreWriter implementation able to write Strings into a SequenceFile.
TextSequenceFileWriter(Configuration, Path, CodecInfo) - Constructor for class org.springframework.data.hadoop.store.output.TextSequenceFileWriter
Instantiates a new text sequence file writer.
toString() - Method in class org.springframework.data.hadoop.store.event.FileWrittenEvent
 
toString() - Method in class org.springframework.data.hadoop.store.support.InputContext
 

U

UuidFileNamingStrategy - Class in org.springframework.data.hadoop.store.strategy.naming
A FileNamingStrategy which uses an uuid.
UuidFileNamingStrategy() - Constructor for class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
Instantiates a new uuid file naming strategy using an UUID.
UuidFileNamingStrategy(String) - Constructor for class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
Instantiates a new uuid file naming strategy using a given uuid string.
UuidFileNamingStrategy(String, boolean) - Constructor for class org.springframework.data.hadoop.store.strategy.naming.UuidFileNamingStrategy
Instantiates a new uuid file naming strategy using a given uuid string.

V

valueOf(String) - Static method in enum org.springframework.data.hadoop.store.codec.Codecs
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.data.hadoop.store.codec.Codecs
Returns an array containing the constants of this enum type, in the order they are declared.
ViewCallback - Interface in org.springframework.data.hadoop.store.dataset
Callback interface for code that creates a View from a Dataset.

W

write(T) - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
 
write(Collection<T>) - Method in interface org.springframework.data.hadoop.store.dataset.DatasetOperations
Write all records provided in the record collection
write(Collection<T>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
 
write(T) - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
 
write(T) - Method in interface org.springframework.data.hadoop.store.DataWriter
Write an entity.
write(T) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
 
write(T, K) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
 
write(List<String>) - Method in class org.springframework.data.hadoop.store.output.DelimitedTextFileWriter
 
write(byte[]) - Method in class org.springframework.data.hadoop.store.output.OutputStreamWriter
 
write(String) - Method in class org.springframework.data.hadoop.store.output.TextFileWriter
 
write(String) - Method in class org.springframework.data.hadoop.store.output.TextSequenceFileWriter
 
write(T, K) - Method in interface org.springframework.data.hadoop.store.PartitionDataStoreWriter
Write an entity with an explicit partitioning key.
writer - Variable in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
 
writer - Variable in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
 
A B C D E F G H I K L M N O P R S T U V W