org.springframework.data.hadoop.store.input

Class AbstractSequenceFileReader

java.lang.Object

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

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

org.springframework.data.hadoop.store.input.AbstractSequenceFileReader

All Implemented Interfaces:

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

Direct Known Subclasses:

TextSequenceFileReader

public abstract class AbstractSequenceFileReader
extends StoreObjectSupport

A AbstractSequenceFileReader is a base implementation handling reads with a SequenceFile.

Author:

Janne Valkealahti

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.hadoop.io.SequenceFile.Reader	getInput()

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

doStart, doStop, getCodec, getConfiguration, getPath, handleIdleTimeout, isCompressed, onInit, resetIdleTimeout, 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

AbstractSequenceFileReader

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

Instantiates a new abstract sequence file reader.

Parameters:

configuration - the hadoop configuration

basePath - the hdfs path

codec - the compression codec info

Method Detail

getInput

protected org.apache.hadoop.io.SequenceFile.Reader getInput()
                                                     throws java.io.IOException

Throws:

java.io.IOException