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:

java.io.Closeable, java.lang.AutoCloseable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, DataReader<java.lang.String>, DataStoreReader<java.lang.String>

public class TextSequenceFileReader
extends AbstractSequenceFileReader
implements DataStoreReader<java.lang.String>

A TextSequenceFileReader is a DataStoreReader implementation able to read Strings from a SequenceFile.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
TextSequenceFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec) Instantiates a new text sequence file reader.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
java.lang.String	read() Read next entity from a reader.

Methods inherited from class org.springframework.data.hadoop.store.input.AbstractSequenceFileReader

getInput

Methods inherited from class org.springframework.data.hadoop.store.support.StoreObjectSupport

doStart, doStop, flushTimeout, getCodec, getConfiguration, getPath, handleTimeout, isCompressed, onInit, resetIdleTimeout, setCloseTimeout, setFlushTimeout, setIdleTimeout

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

Constructor Detail

TextSequenceFileReader

public TextSequenceFileReader(org.apache.hadoop.conf.Configuration configuration,
                      org.apache.hadoop.fs.Path basePath,
                      CodecInfo codec)

Instantiates a new text sequence file reader.

Parameters:

configuration - the hadoop configuration

basePath - the hdfs path

codec - the compression codec info

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

read

public java.lang.String read()
                      throws java.io.IOException

Description copied from interface: DataReader

Read next entity from a reader.

Specified by:

read in interface DataReader<java.lang.String>

Returns:

the entity or null

Throws:

java.io.IOException - if an I/O error occurs