public class TextFileReader extends AbstractDataStreamReader implements DataStoreReader<String>
TextFileReader is a DataStoreReader implementation
able to read Strings from a raw hdfs files.AbstractDataStreamReader.ReaderHelper<T,V>| Constructor and Description |
|---|
TextFileReader(Configuration configuration,
Path basePath,
CodecInfo codec)
Instantiates a new text file reader.
|
TextFileReader(Configuration configuration,
Path basePath,
CodecInfo codec,
Split split)
Instantiates a new text file reader.
|
TextFileReader(Configuration configuration,
Path basePath,
CodecInfo codec,
Split split,
byte[] delimiter)
Instantiates a new text file reader.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
String |
read()
Read next entity from a reader.
|
getInputgetInputContext, 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 TextFileReader(Configuration configuration, Path basePath, CodecInfo codec)
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infopublic TextFileReader(Configuration configuration, Path basePath, CodecInfo codec, Split split)
configuration - the configurationbasePath - the base pathcodec - the codecsplit - the input splitpublic TextFileReader(Configuration configuration, Path basePath, CodecInfo codec, Split split, byte[] delimiter)
configuration - the configurationbasePath - the base pathcodec - the codecsplit - the input splitdelimiter - the delimiterpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableIOExceptionpublic String read() throws IOException
DataReaderread in interface DataReader<String>nullIOException - if an I/O error occurs