| Interface | Description |
|---|---|
| ReadableByteChannelDecorator<T extends ReadableByteChannel> | |
| SeekableDecorator |
| Class | Description |
|---|---|
| FileSplitUtils | |
| InputStreamWithCloseIgnore | |
| 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.
|
| InterruptingReadableByteChannel |
ReadabalByteChannel whose read method is guaranteed to return at a specific position
(before crossing it) such as a split boundary
|
| ReadableByteChannelDecoratorBase<T extends ReadableByteChannel> | |
| ReadableByteChannelWithConditionalBound<T extends ReadableByteChannel> |
Readable byte channel wrapper that before every read checks for an
end-of-file (eof) condition.
|
| ReadableByteChannelWithoutCloseOnInterrupt |
ReadableByteChannel from an InputStream without closing the stream on interrupt as
Channels.newChannel does.
|
| SeekableInputStream |
Combines Hadoop's Seekable and InputStream into one class
|
Copyright © 2016–2021 Smart Data Analytics (SDA) Research Group. All rights reserved.