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

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

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:

AbstractDataStreamReader

public class InputStoreObjectSupport
extends StoreObjectSupport

Base class for input readers sharing common functionality for Split and InputContext.

Author:

Janne Valkealahti

Constructor Summary

InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec)
Instantiates a new input store object support.

InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split split)
Instantiates a new input store object support.

Method Summary

InputContext	getInputContext() Gets the input context.
Split	getSplit() Gets the input split.

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

InputStoreObjectSupport

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

Instantiates a new input store object support.

Parameters:

configuration - the configuration

basePath - the base path

codec - the codec

InputStoreObjectSupport

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

Instantiates a new input store object support.

Parameters:

configuration - the configuration

basePath - the base path

codec - the codec

split - the input split

Method Detail

getSplit

public Split getSplit()

Gets the input split.

Returns:

the input split

getInputContext

public InputContext getInputContext()

Gets the input context.

Returns:

the input context