public class AbstractDataStreamReader extends InputStoreObjectSupport
AbstractDataStreamReader is a base implementation handling
 streams with a raw hdfs files.| Modifier and Type | Class and Description | 
|---|---|
| protected static class  | AbstractDataStreamReader.ReaderHelper<T,V>Reader helper hiding complexity of working with input streams. | 
| Constructor and Description | 
|---|
| AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration,
                        org.apache.hadoop.fs.Path basePath,
                        CodecInfo codec)Instantiates a new abstract data stream reader. | 
| AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration,
                        org.apache.hadoop.fs.Path basePath,
                        CodecInfo codec,
                        Split split)Instantiates a new abstract data stream reader. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected StreamsHolder<java.io.InputStream> | getInput()Creates a holder wrapping input stream. | 
getInputContext, getSplitdoStart, doStop, getCodec, getConfiguration, getPath, handleIdleTimeout, isCompressed, onInit, resetIdleTimeout, setIdleTimeoutafterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration,
                        org.apache.hadoop.fs.Path basePath,
                        CodecInfo codec)
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infopublic AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration,
                        org.apache.hadoop.fs.Path basePath,
                        CodecInfo codec,
                        Split split)
configuration - the configurationbasePath - the base pathcodec - the compression codec infosplit - the input splitprotected StreamsHolder<java.io.InputStream> getInput() throws java.io.IOException
java.io.IOException - Signals that an I/O exception has occurred.