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

java.lang.Object
  org.springframework.data.hadoop.store.support.LifecycleObjectSupport
      org.springframework.data.hadoop.store.support.StoreObjectSupport
          org.springframework.data.hadoop.store.input.AbstractDataStreamReader

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:

TextFileReader

public class AbstractDataStreamReader
extends StoreObjectSupport

A AbstractDataStreamReader is a base implementation handling streams with a raw hdfs files.

Author:

Janne Valkealahti

Constructor Summary

AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec)
Instantiates a new abstract data stream reader.

Method Summary

protected StreamsHolder<java.io.InputStream>

getInput(org.apache.hadoop.fs.Path inputPath) Gets the input.

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

AbstractDataStreamReader

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

Instantiates a new abstract data stream reader.

Parameters:

configuration - the hadoop configuration

basePath - the hdfs path

codec - the compression codec info

Method Detail

getInput

protected StreamsHolder<java.io.InputStream> getInput(org.apache.hadoop.fs.Path inputPath)
                                               throws java.io.IOException

Gets the input.

Parameters:

inputPath - the input path

Returns:

the input

Throws:

java.io.IOException - Signals that an I/O exception has occurred.