All Classes Interface Summary Class Summary
Class |
Description |
Accumulating<T,G,A,U> |
|
ConfigurationUtils |
|
CsvUtils |
|
CsvUtils |
|
DeferredSeekablePushbackInputStream |
A wrapper for hadoop input streams created from codecs in ReadMode.BY_BLOCK:
Defers reading by one byte such that position changes are advertised on the byte BEFORE
the block boundary rather than on the byte AFTER it.
|
FileInputFormatCsv |
|
FileInputFormatCsv |
|
FileInputFormatJsonArray |
|
FileInputFormatRdfBase<T> |
Base class for unit testing of reading an RDF file with
an arbitrary number of splits.
|
FileInputFormatRdfTrigDataset |
|
FileInputFormatRdfTrigQuad |
|
FileInputFormatRdfTurtleTriple |
|
FileOutputFormatTrig2<TKey> |
Not yet used; the idea is to provide an improved version of elepha's TrigOutputFormat
|
FileSplitUtils |
|
InputStreamWithCloseIgnore |
A wrapper whose close() method is a noop.
|
InputStreamWithCloseLogging |
Util class to debug a stream already closed exception
|
InputStreamWithZeroOffsetRead |
Workaround for HADOOP-17453: read(bts, off, len) with off != 0 is broken in several version of BZip2Codec
Invoking read with a non-zero offset creates a in intermediate buffer to which is read with a zero offset
The content of the intermidate buffer is then copied to the requesting buffer bts at the appropriate offset.
|
InterruptingSeekableByteChannel |
|
LocatorHdfs |
Support for resources using the "http:" and "https" schemes
|
ReadableByteChannelDecorator |
|
ReadableByteChannelDecoratorBase<T extends ReadableByteChannel> |
|
ReadableByteChannelFromInputStream |
A replacement for Channels.newChannel with the following changes for
interoperability with hadoop and our GenericRecordReader:
- Does not close the underlying stream on interrupt
- This implementation's read method just delegates to the input stream
(without additional buffering / repeated reads).
|
ReadableByteChannelWithConditionalBound<T extends ReadableByteChannel> |
Readable byte channel wrapper that before every read checks for an
end-of-file (eof) condition.
|
RecordReaderCsv |
A generic parser implementation for CSV with the offset-seeking condition that
CSV rows must all have the same length.
|
RecordReaderCsv |
A generic parser implementation for CSV with the offset-seeking condition that
CSV rows must all have the same length.
|
RecordReaderGenericBase<U,G,A,T> |
A generic record reader that uses a callback mechanism to detect a consecutive sequence of records
that must start in the current split and which may extend over any number of successor splits.
|
RecordReaderGenericRdfAccumulatingBase<U,G,A,T> |
|
RecordReaderGenericRdfBase<U,G,A,T> |
|
RecordReaderGenericRdfNonAccumulatingBase<T> |
|
RecordReaderJsonArray |
|
RecordReaderRdfTrigDataset |
RecordReader for the Trig RDF format that groups consecutive quads having the
same IRI for the graph component into Datasets.
|
RecordReaderRdfTrigDataset.AccumulatingDataset |
|
RecordReaderRdfTrigQuad |
|
RecordReaderRdfTurtleTriple |
|
SeekableByteChannelDecorator |
|
SeekableByteChannelDecoratorBase<T extends SeekableByteChannel> |
|
SeekableByteChannelFromSeekableInputStream |
|
SeekableDecorator |
|
SeekableInputStream |
A basic wrapper that combines Hadoop's Seekable and InputStream into one class.
|
SeekablePushbackInputStream |
|