org.springframework.data.hadoop.store.input
Class TextSequenceFileReader
java.lang.Object
org.springframework.data.hadoop.store.support.LifecycleObjectSupport
org.springframework.data.hadoop.store.support.StoreObjectSupport
org.springframework.data.hadoop.store.input.AbstractSequenceFileReader
org.springframework.data.hadoop.store.input.TextSequenceFileReader
- All Implemented Interfaces:
- Closeable, Aware, BeanFactoryAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, DataReader<String>, DataStoreReader<String>
public class TextSequenceFileReader
- extends AbstractSequenceFileReader
- implements DataStoreReader<String>
A TextSequenceFileReader is a DataStoreReader implementation
able to read Strings from a SequenceFile.
- Author:
- Janne Valkealahti
| Methods inherited from class org.springframework.data.hadoop.store.support.LifecycleObjectSupport |
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stop |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TextSequenceFileReader
public TextSequenceFileReader(Configuration configuration,
Path basePath,
CodecInfo codec)
- Instantiates a new text sequence file reader.
- Parameters:
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec info
close
public void close()
throws IOException
- Specified by:
close in interface Closeable
- Throws:
IOException
read
public String read()
throws IOException
- Description copied from interface:
DataReader
- Read next entity from a reader.
- Specified by:
read in interface DataReader<String>
- Returns:
- the entity or
null
- Throws:
IOException - if an I/O error occurs