T - the type of readerV - the type of data returned by readerprotected abstract static class AbstractDataStreamReader.ReaderHelper<T,V> extends Object
| Modifier | Constructor and Description | 
|---|---|
| protected  | AbstractDataStreamReader.ReaderHelper(StreamsHolder<InputStream> streamsHolder,
                                     InputContext inputContext,
                                     Split split,
                                     CodecInfo codec)Instantiates a new reader helper. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected abstract T | createReader(InputStream inputStream)Creates the reader. | 
| protected abstract V | doRead(T delegate)Do read. | 
| protected InputContext | getContext()Gets the wrapped  InputContext. | 
| protected StreamsHolder<InputStream> | getHolder()Gets the  StreamsHolderfor wrapped
 input stream. | 
| protected T | getReader()Gets the reader created by  createReader(InputStream). | 
| protected void | init()Inits the reader helper. | 
| protected void | processReadCount(int readSize)Processing a count of bytes read from a stream. | 
| protected V | read()Reads a data by delegating to a reader. | 
protected AbstractDataStreamReader.ReaderHelper(StreamsHolder<InputStream> streamsHolder, InputContext inputContext, Split split, CodecInfo codec)
streamsHolder - the streams holderinputContext - the input contextsplit - the input splitcodec - the compression codec infoprotected abstract T createReader(InputStream inputStream) throws IOException
inputStream - the input streamIOException - Signals that an I/O exception has occurred.protected abstract V doRead(T delegate) throws IOException
delegate - the delegate readerIOException - Signals that an I/O exception has occurred.protected void init()
             throws IOException
IOException - Signals that an I/O exception has occurred.protected void processReadCount(int readSize)
                         throws IOException
Seekable depending if it has been set.readSize - the read sizeIOException - Signals that an I/O exception has occurred.protected V read() throws IOException
IOException - Signals that an I/O exception has occurred.protected T getReader()
createReader(InputStream).protected StreamsHolder<InputStream> getHolder()
StreamsHolder for wrapped
 input stream.protected InputContext getContext()
InputContext.