T - the type of readerV - the type of data returned by readerprotected abstract static class AbstractDataStreamReader.ReaderHelper<T,V>
extends java.lang.Object
| Modifier | Constructor and Description | 
|---|---|
| protected  | AbstractDataStreamReader.ReaderHelper(StreamsHolder<java.io.InputStream> streamsHolder,
                                     InputContext inputContext,
                                     Split split,
                                     CodecInfo codec)Instantiates a new reader helper. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected abstract T | createReader(java.io.InputStream inputStream)Creates the reader. | 
| protected abstract V | doRead(T delegate)Do read. | 
| protected InputContext | getContext()Gets the wrapped  InputContext. | 
| protected StreamsHolder<java.io.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<java.io.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(java.io.InputStream inputStream) throws java.io.IOException
inputStream - the input streamjava.io.IOException - Signals that an I/O exception has occurred.protected abstract V doRead(T delegate) throws java.io.IOException
delegate - the delegate readerjava.io.IOException - Signals that an I/O exception has occurred.protected void init()
             throws java.io.IOException
java.io.IOException - Signals that an I/O exception has occurred.protected void processReadCount(int readSize)
                         throws java.io.IOException
Seekable depending if it has been set.readSize - the read sizejava.io.IOException - Signals that an I/O exception has occurred.protected V read() throws java.io.IOException
java.io.IOException - Signals that an I/O exception has occurred.protected T getReader()
createReader(InputStream).protected StreamsHolder<java.io.InputStream> getHolder()
StreamsHolder for wrapped
 input stream.protected InputContext getContext()
InputContext.