- AbstractDatasetStoreReader<T,R> - Class in org.springframework.data.hadoop.store.dataset
-
An abstract DataStoreReader to be extended for providing Dataset reading
capabilities for specific use cases.
- AbstractDatasetStoreReader(Class<T>, DatasetRepositoryFactory, DatasetDefinition) - Constructor for class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Instantiates a new abstract dataset store reader.
- AbstractDatasetStoreWriter<T,R> - 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
-
- 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
-
- 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
-
- 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
-
- append(boolean) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- append(boolean) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify if writer is allowed to do file append.
- AvroPojoDatasetStoreReader<T> - Class in org.springframework.data.hadoop.store.dataset
-
A DataStoreReader for reading Datasets using the Avro format.
- AvroPojoDatasetStoreReader(Class<T>, DatasetRepositoryFactory, DatasetDefinition) - Constructor for class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreReader
-
- 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.
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor
-
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- canRead(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- canWrite(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- canWrite(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- canWrite(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- 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.AbstractDatasetStoreReader
-
- close() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
- 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.
- closeTimeout(long) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- closeTimeout(long) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's close timeout.
- codec(CodecInfo) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- codec(String) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- codec(Codecs) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- codec(CodecInfo) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's compression coded.
- codec(String) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's compression coded.
- codec(Codecs) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's compression coded.
- codec() - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultNamingStrategyConfigurer
-
- codec() - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.NamingStrategyConfigurer
-
Adds a codec naming part to a strategy.
- 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
-
- configuration(Configuration) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- configuration(Configuration) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's Hadoop configuration.
- configure(DataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultNamingStrategyConfigurer
-
- configure(DataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultPartitionStrategyConfigurer
-
- configure(DataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultRolloverStrategyConfigurer
-
- configure(DataStoreTextWriterConfigurer) - Method in interface org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurer
-
- configure(SpringDataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- configure(DataStoreTextWriterConfigurer) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- convertEntity(R) - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Convert entity used by a reading into a entity
returned.
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
Convert entity to be written into a entity used
by a writer.
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreReader
-
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
-
- convertEntity(GenericRecord) - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreReader
-
- convertEntity(T) - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
-
- 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
-
- 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
-
- createInstance() - Method in class org.springframework.data.hadoop.store.strategy.rollover.SizeRolloverStrategy
-
- createOptimalAccessor(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor
-
- createOptimalAccessor(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- createReader() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Creates a DatasetReader.
- createReader() - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreReader
-
- createReader() - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreReader
-
- createReader(InputStream) - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
-
Creates the reader.
- createWriter() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
Creates a DatasetWriter.
- createWriter() - Method in class org.springframework.data.hadoop.store.dataset.AvroPojoDatasetStoreWriter
-
- createWriter() - Method in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
-
- 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
- custom(PartitionStrategy<?, ?>) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultPartitionStrategyConfigurer
-
- custom(PartitionStrategy<?, ?>) - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.PartitionStrategyConfigurer
-
- 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 - 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 - 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
-
- DatasetStoreObjectSupport - Class in org.springframework.data.hadoop.store.dataset
-
Support class adding timeout poller functionality.
- DatasetStoreObjectSupport() - Constructor for class org.springframework.data.hadoop.store.dataset.DatasetStoreObjectSupport
-
- 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.
- DataStoreTextWriterBuilder - Class in org.springframework.data.hadoop.store.config.annotation.builders
-
- DataStoreTextWriterBuilder() - Constructor for class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
Instantiates a new data store writer builder.
- DataStoreTextWriterBuilder(ObjectPostProcessor<Object>) - Constructor for class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
Instantiates a new data store writer builder.
- DataStoreTextWriterConfigurer - Interface in org.springframework.data.hadoop.store.config.annotation.builders
-
- 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
-
- dateFormat(String) - Method in class org.springframework.data.hadoop.store.expression.MessageExpressionMethods.MessageWrappedMessage
-
- DateFormatMethodExecutor - Class in org.springframework.data.hadoop.store.expression
-
- 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.
- DefaultNamingStrategyConfigurer - Class in org.springframework.data.hadoop.store.config.annotation.configurers
-
AnnotationConfigurer which knows howto configure a naming strategy.
- DefaultNamingStrategyConfigurer() - Constructor for class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultNamingStrategyConfigurer
-
- 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, StandardEvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
- DefaultPartitionStrategy(String) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
Instantiates a new default partition strategy.
- DefaultPartitionStrategy(String, StandardEvaluationContext) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
- DefaultPartitionStrategy(String, StandardEvaluationContext, ExpressionParser) - Constructor for class org.springframework.data.hadoop.store.partition.DefaultPartitionStrategy
-
- DefaultPartitionStrategyConfigurer - Class in org.springframework.data.hadoop.store.config.annotation.configurers
-
AnnotationConfigurer which knows howto configure a partition strategy.
- DefaultPartitionStrategyConfigurer() - Constructor for class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultPartitionStrategyConfigurer
-
- DefaultRolloverStrategyConfigurer - Class in org.springframework.data.hadoop.store.config.annotation.configurers
-
AnnotationConfigurer which knows howto configure a rollover strategy.
- DefaultRolloverStrategyConfigurer() - Constructor for class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultRolloverStrategyConfigurer
-
- 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.dataset.DatasetStoreObjectSupport
-
- 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.dataset.DatasetStoreObjectSupport
-
- 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
-
- generateCode(String, MethodVisitor, CodeFlow) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- generateCode(String, MethodVisitor, CodeFlow) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- GenericSplit - Class in org.springframework.data.hadoop.store.split
-
- 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.
- getAnnotations() - Method in class org.springframework.data.hadoop.store.config.annotation.configuration.SpringDataStoreTextWriterConfiguration
-
- getAppendable() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- getBasePath() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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
-
- getBlockIndex(BlockLocation[], long) - Method in class org.springframework.data.hadoop.store.split.AbstractSplitter
-
Gets the block index.
- getCloseTimeout() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- getCloseTimeout() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Gets the close timeout.
- getCodec() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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.
- getCompressionType() - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- getConfigBuilder() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- getConfiguration() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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
-
- getDataset(DatasetRepositoryFactory, Class<T>) - Static method in class org.springframework.data.hadoop.store.dataset.DatasetUtils
-
- getDatasetDefinition() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Gets the dataset definition.
- getDatasetDefinition() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
Gets the dataset definition.
- getDatasetDefinitions() - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- 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
-
Gets the dataset name.
- getDatasetRepository() - Method in class org.springframework.data.hadoop.store.dataset.DatasetRepositoryFactory
-
Get the DatasetRepository
- getDatasetRepositoryFactory() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Gets the dataset repository factory.
- getDatasetRepositoryFactory() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
Gets the dataset repository factory.
- getDefaultDatasetDefinition() - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- 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
-
- getEntityClass() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
Gets the entity class.
- getEntityClass() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreWriter
-
Gets the entity class.
- getEventPublisher(BeanFactory) - Static method in class org.springframework.data.hadoop.store.support.StoreContextUtils
-
- getFileNamingStrategy() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- getFileNamingStrategyFactory() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Gets the file naming strategy factory.
- getFileOpenAttempts() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- getFormat() - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- getHeaders() - Method in class org.springframework.data.hadoop.store.expression.MessageExpressionMethods.MessageWrappedMessage
-
- getHolder() - Method in class org.springframework.data.hadoop.store.input.AbstractDataStreamReader.ReaderHelper
-
- getIdleTimeout() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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.
- getOverwrite() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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.
- getPayload() - Method in class org.springframework.data.hadoop.store.expression.MessageExpressionMethods.MessageWrappedMessage
-
- 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
-
- getPropertyType() - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- getPropertyType() - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- 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.
- getRolloverStrategy() - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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
-
- getSpecificTargetClasses() - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor
-
- getSpecificTargetClasses() - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- getSpecificTargetClasses() - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- getSpecificTargetClasses() - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- 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
-
- 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
-
- 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.
- getValue(Expression, Message<?>, Class<T>) - Method in class org.springframework.data.hadoop.store.expression.MessageExpressionMethods
-
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
-
- idleTimeout(long) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- idleTimeout(long) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's idle timeout.
- 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(SpringDataStoreTextWriterBuilder) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- 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.
- inWritingPrefix(String) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- inWritingPrefix(String) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's in-use prefix.
- inWritingSuffix(String) - Method in class org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterBuilder
-
- inWritingSuffix(String) - Method in interface org.springframework.data.hadoop.store.config.annotation.builders.DataStoreTextWriterConfigurer
-
Specify a writer's in-use suffix.
- 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
- isAssignable(AnnotationBuilder<SpringDataStoreWriterConfigs>) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- isAutoStartup() - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
- isClosed() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Checks if this writer is closed.
- isCompilable() - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- isCompilable() - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- 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
-
- isSyncable() - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Checks if syncable is enabled.
- isSyncable() - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
-
Checks if syncable is enabled.
- iterator() - Method in class org.springframework.data.hadoop.store.support.OrderedComposite
-
Public getter for the list of items.
- 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() - Method in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
- 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(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor.MapOptimalPropertyAccessor
-
- read(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MapPartitionKeyPropertyAccessor
-
- read(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor.MessageOptimalPropertyAccessor
-
- read(EvaluationContext, Object, String) - Method in class org.springframework.data.hadoop.store.expression.MessagePartitionKeyPropertyAccessor
-
- 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
-
- reader - Variable in class org.springframework.data.hadoop.store.dataset.AbstractDatasetStoreReader
-
- 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.dataset.DatasetStoreObjectSupport
-
Reset idle timeout.
- 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.
- rolling() - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultNamingStrategyConfigurer
-
- rolling() - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.NamingStrategyConfigurer
-
Adds a rolling naming part to a strategy.
- 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.
- RolloverStrategyConfigurer - Interface in org.springframework.data.hadoop.store.config.annotation.configurers
-
AnnotationConfigurerBuilder for configuring a rollover strategy.
- RolloverStrategyFactory<T extends RolloverStrategy> - Interface in org.springframework.data.hadoop.store.strategy.rollover
-
- rollStrategies() - Method in class org.springframework.data.hadoop.store.support.OutputContext
-
Roll strategies.
- schema - Variable in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreReader
-
- schema - Variable in class org.springframework.data.hadoop.store.dataset.ParquetDatasetStoreWriter
-
- SequenceFileWriterHolder<T extends 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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(Path) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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
-
- setCloseTimeout(Long) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- setCloseTimeout(long) - Method in class org.springframework.data.hadoop.store.dataset.DatasetStoreObjectSupport
-
Sets the close timeout.
- setCloseTimeout(long) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Sets the close timeout.
- setCloseTimeout(long) - Method in class org.springframework.data.hadoop.store.support.StoreObjectSupport
-
Sets the close timeout.
- setCodec(CodecInfo) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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.
- setCompressionType(String) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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
-
- setDatasetRepositoryFactory(DatasetRepositoryFactory) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- setDefaultDatasetDefinition(DatasetDefinition) - Method in class org.springframework.data.hadoop.store.dataset.DatasetTemplate
-
- 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.config.annotation.builders.DataStoreTextWriterBuilder
-
Sets the file naming strategy for this builder.
- setFileNamingStrategy(FileNamingStrategy) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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.
- setFileOpenAttempts(Integer) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- setFormat(String) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- setIdleTimeout(Long) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- setIdleTimeout(long) - Method in class org.springframework.data.hadoop.store.dataset.DatasetStoreObjectSupport
-
Sets the idle timeout.
- 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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.
- setObjectPostProcessor(ObjectPostProcessor<Object>) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- 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.config.annotation.SpringDataStoreWriterConfigs
-
- 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.config.annotation.builders.DataStoreTextWriterBuilder
-
Sets the partition strategy for this builder.
- setPartitionStrategy(PartitionStrategy<?, ?>) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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.config.annotation.builders.DataStoreTextWriterBuilder
-
Sets the rollover strategy for this builder.
- setRolloverStrategy(RolloverStrategy) - Method in class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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.
- setSchema(Schema) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- 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
-
- setStopWaitResultsTimeout(long) - Method in class org.springframework.data.hadoop.store.support.PollingTaskSupport
-
Sets the stop wait results timeout.
- setStoreEventPublisher(StoreEventPublisher) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
Sets the store event publisher.
- setStrategies(List<? extends FileNamingStrategy>) - Method in class org.springframework.data.hadoop.store.strategy.naming.ChainedFileNamingStrategy
-
Sets the list of strategies.
- setStrategies(List<? extends RolloverStrategy>) - Method in class org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy
-
Sets the list of strategies.
- setStream(T) - Method in class org.springframework.data.hadoop.store.support.StreamsHolder
-
Sets the stream.
- setSyncable(boolean) - Method in class org.springframework.data.hadoop.store.output.AbstractPartitionDataStoreWriter
-
Sets the syncable.
- setSyncable(boolean) - Method in class org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
-
Sets the syncable.
- setTargetClass(Class<?>) - Method in class org.springframework.data.hadoop.store.dataset.DatasetDefinition
-
- setTaskExecutor(TaskExecutor) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
- setTaskScheduler(TaskScheduler) - Method in class org.springframework.data.hadoop.store.support.LifecycleObjectSupport
-
- 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
-
- size(long) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultRolloverStrategyConfigurer
-
- size(String) - Method in class org.springframework.data.hadoop.store.config.annotation.configurers.DefaultRolloverStrategyConfigurer
-
- size(long) - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.RolloverStrategyConfigurer
-
Specify a rollover size in bytes.
- size(String) - Method in interface org.springframework.data.hadoop.store.config.annotation.configurers.RolloverStrategyConfigurer
-
Specify a rollover size.
- 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.
- SpringDataStoreTextWriterBuilder - Class in org.springframework.data.hadoop.store.config.annotation.builders
-
- SpringDataStoreTextWriterBuilder() - Constructor for class org.springframework.data.hadoop.store.config.annotation.builders.SpringDataStoreTextWriterBuilder
-
- SpringDataStoreTextWriterConfiguration - Class in org.springframework.data.hadoop.store.config.annotation.configuration
-
- SpringDataStoreTextWriterConfiguration() - Constructor for class org.springframework.data.hadoop.store.config.annotation.configuration.SpringDataStoreTextWriterConfiguration
-
- SpringDataStoreTextWriterConfigurer - Interface in org.springframework.data.hadoop.store.config.annotation
-
Allows for configuring a AnnotationBuilder.
- SpringDataStoreTextWriterConfigurerAdapter - Class in org.springframework.data.hadoop.store.config.annotation
-
- SpringDataStoreTextWriterConfigurerAdapter() - Constructor for class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreTextWriterConfigurerAdapter
-
- SpringDataStoreWriterConfigs - Class in org.springframework.data.hadoop.store.config.annotation
-
A holder object for all configured configs for Spring Hadoop.
- SpringDataStoreWriterConfigs() - Constructor for class org.springframework.data.hadoop.store.config.annotation.SpringDataStoreWriterConfigs
-
- 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 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.