|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
AbstractDataStreamReader is a base implementation handling
streams with a raw hdfs files.AbstractDataStreamWriter is a base implementation handling
streams with a raw hdfs files.FileNamingStrategy implementations.RolloverStrategy implementations.AbstractSequenceFileReader is a base implementation handling
reads with a SequenceFile.AbstractSequenceFileWriter is a base implementation handling
writes with a SequenceFile.ApplicationEvent class for store based events.FileNamingStrategy chaining other strategies.RolloverStrategy which is simply chaining other strategies.FileNamingStrategy which adds suffix based on known codec.DataReader is an interface for reader implementation
able to read entities from a store.Dataset operations against a specific
DatasetRepository.DatasetRepository.DatasetRepository instances.DataStoreReader is an extension of DataReader
adding methods from Closeable interface.DataStoreWriter is an extension of DataWriter
adding methods from Flushable and Closeable
interfaces.DataWriter is an interface for writer implementation
able to write entities into a store.CodecInfo implementation.DelimitedTextFileReader is a DataStoreReader implementation
able to read Strings from a raw hdfs files as delimited fields.DelimitedTextFileWriter is a DataStoreWriter implementation
able to write Strings into raw hdfs files as delimited fields.DatasetRepository
Path has been written.Codecs by its abbreviation.
BeanFactory for this instance.
CodecInfo by Codecs abbreviation.
DatasetRepository
StoreEventPublisher bean whose name is "storeEventPublisher" if available.
TaskExecutor.
TaskScheduler bean whose name is "taskExecutor" if available.
TaskScheduler.
TaskScheduler bean whose name is "taskScheduler" if available.
Trigger for idle timeout task execution.ApplicationListener which logs all events based on
AbstractStoreEvent using a log level set during the construction.RolloverStrategy which simply never does a rollover.OutputStoreObjectSupport is meant to be used from a store
DataWriter implementations by keeping current writing state.OutputStreamWriter is a DataStoreWriter implementation
able to write byte[]s into raw hdfs files.TaskScheduler and TaskExecutor.AbstractStoreEvent.
Dataset record.FileNamingStrategy which simply uses a rolling counter to give unique file name.SequenceFile writer.DatasetRepositoryFactory to use for this template.
TaskExecutor.
TaskScheduler.
RolloverStrategy using a size limiting a rollover operation.FileNamingStrategy which simply uses a static file name.TextFileReader is a DataStoreReader implementation
able to read Strings from a raw hdfs files.TextFileWriter is a DataStoreWriter implementation
able to write Strings into raw hdfs files.TextSequenceFileReader is a DataStoreReader implementation
able to read Strings from a SequenceFile.TextSequenceFileWriter is a DataStoreWriter implementation
able to write Strings into a SequenceFile.
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||