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

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

Method Summary

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