|
|||||||||
| 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.Splitter implementations.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.DatasetDataset 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.GenericSplit is simple implementation of
Split and SplitLocation storing needed
information as it is.Codecs by its abbreviation.
BeanFactory for this instance.
CodecInfo by Codecs abbreviation.
InputContext.
DatasetRepository
DatasetDefinition to use for this template.
StoreEventPublisher bean whose name is "storeEventPublisher" if available.
StreamsHolder for wrapped
input stream.
AbstractDataStreamReader.ReaderHelper.createReader(InputStream).
Path.
TaskExecutor.
TaskScheduler bean whose name is "taskExecutor" if available.
TaskScheduler.
TaskScheduler bean whose name is "taskScheduler" if available.
Trigger for idle timeout task execution.Split and InputContext.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.
DatasetDefinition to use for this template.
TaskExecutor.
TaskScheduler.
RolloverStrategy using a size limiting a rollover operation.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.Split.Splits based on a
Path representing a hdfs resource.StaticBlockSplitter is a Splitter handling
splits as relative of block sizes allowing to furthern split
blocks on a smaller chunks.FileNamingStrategy which simply uses a static file name.StaticLengthSplitter is a Splitter using
a static length to split a resource into an equal sized.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 | ||||||||