org.springframework.data.hadoop.store.input

Class TextFileReader

java.lang.Object

org.springframework.data.hadoop.store.support.LifecycleObjectSupport

org.springframework.data.hadoop.store.support.StoreObjectSupport

org.springframework.data.hadoop.store.support.InputStoreObjectSupport

org.springframework.data.hadoop.store.input.AbstractDataStreamReader

org.springframework.data.hadoop.store.input.TextFileReader

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 TextFileReader
extends AbstractDataStreamReader
implements DataStoreReader<java.lang.String>

A TextFileReader is a DataStoreReader implementation able to read Strings from a raw hdfs files.

Author:

Janne Valkealahti

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.data.hadoop.store.input.AbstractDataStreamReader

AbstractDataStreamReader.ReaderHelper<T,V>

Constructor Summary

Constructors

Constructor and Description
TextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec) Instantiates a new text file reader.
TextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split split) Instantiates a new text file reader.
TextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split split, byte[] delimiter) Instantiates a new text 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.AbstractDataStreamReader

getInput

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

getInputContext, getSplit

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

TextFileReader

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

Instantiates a new text file reader.

Parameters:

configuration - the hadoop configuration

basePath - the hdfs path

codec - the compression codec info

TextFileReader

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

Instantiates a new text file reader.

Parameters:

configuration - the configuration

basePath - the base path

codec - the codec

split - the input split

TextFileReader

public TextFileReader(org.apache.hadoop.conf.Configuration configuration,
              org.apache.hadoop.fs.Path basePath,
              CodecInfo codec,
              Split split,
              byte[] delimiter)

Instantiates a new text file reader.

Parameters:

configuration - the configuration

basePath - the base path

codec - the codec

split - the input split

delimiter - the delimiter

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