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(Configuration configuration,
Path basePath,
CodecInfo codec)
Instantiates a new abstract data stream reader.
|
AbstractDataStreamReader(Configuration configuration,
Path basePath,
CodecInfo codec,
Split split)
Instantiates a new abstract data stream reader.
|
| Modifier and Type | Method and Description |
|---|---|
protected StreamsHolder<InputStream> |
getInput()
Creates a holder wrapping input stream.
|
getInputContext, getSplitdoStart, doStop, getCodec, getConfiguration, getPath, handleTimeout, isCompressed, onInit, resetIdleTimeout, setCloseTimeout, setIdleTimeoutafterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic AbstractDataStreamReader(Configuration configuration, Path basePath, CodecInfo codec)
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infopublic AbstractDataStreamReader(Configuration configuration, Path basePath, CodecInfo codec, Split split)
configuration - the configurationbasePath - the base pathcodec - the compression codec infosplit - the input splitprotected StreamsHolder<InputStream> getInput() throws IOException
IOException - Signals that an I/O exception has occurred.